org.springframework.cloud.stream.binder

Interface PollableConsumerBinder<H,C extends ConsumerProperties>

Type Parameters:

H - the polled consumer handler type.

C - the consumer properties type.

All Known Implementing Classes:

AbstractMessageChannelBinder, KafkaMessageChannelBinder, RabbitMessageChannelBinder

public interface PollableConsumerBinder<H,C extends ConsumerProperties>

A binder that supports pollable message sources.

Since:

2.0

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
default Binding<PollableSource<H>>	bindPollableConsumer(String name, String group, PollableSource<H> inboundBindTarget, C consumerProperties) Configure a binding for a pollable message source.

Method Detail

bindPollableConsumer

default Binding<PollableSource<H>> bindPollableConsumer(String name,
                                                        String group,
                                                        PollableSource<H> inboundBindTarget,
                                                        C consumerProperties)

Configure a binding for a pollable message source.

Parameters:

name - the binding name.

group - the consumer group.

inboundBindTarget - the binding target.

consumerProperties - the consumer properties.

Returns:

the binding.