Как продлить время аренды при использовании обработчиков на основе Spring Cloud Stream Reactor

Question

Обработчики на основе Reactor spring-cloud-stream обеспечивают аккуратный интерфейс для реактивного использования сообщений:

@EnableBinding(Processor.class)
@EnableAutoConfiguration
public static class UppercaseTransformer {

    @StreamListener
    @Output(Processor.OUTPUT)
    public Flux<String> receive(@Input(Processor.INPUT) Flux<String> input) {
        return input.map(message -> message.toUpperCase());
    }

}

Хотя для определенного типа потребляемых сообщений может возникнуть необходимостьпродлить настроенное время аренды по умолчанию.Как этого добиться?