Package org.springframework.cloud.stream.binder

Class AbstractPollableConsumerTestBinder<C extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,CP,PP>,CP extends org.springframework.cloud.stream.binder.ConsumerProperties,PP extends org.springframework.cloud.stream.binder.ProducerProperties>

java.lang.Object

org.springframework.cloud.stream.binder.AbstractTestBinder<C,CP,PP>

org.springframework.cloud.stream.binder.AbstractPollableConsumerTestBinder<C,CP,PP>

Type Parameters:

C - binder type

CP - consumer properties type

PP - producer properties type

All Implemented Interfaces:

org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel,CP,PP>, org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,CP>

public abstract class AbstractPollableConsumerTestBinder<C extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,CP,PP>,CP extends org.springframework.cloud.stream.binder.ConsumerProperties,PP extends org.springframework.cloud.stream.binder.ProducerProperties>
extends AbstractTestBinder<C,CP,PP>
implements org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,CP>

Since:

2.0

Author:

Gary Russell

Field Summary

Fields inherited from class org.springframework.cloud.stream.binder.AbstractTestBinder

queues

Constructor Summary

Constructors

Constructor	Description
AbstractPollableConsumerTestBinder()

Method Summary

Modifier and Type	Method	Description
org.springframework.cloud.stream.binder.Binding<org.springframework.cloud.stream.binder.PollableSource<org.springframework.messaging.MessageHandler>>	bindPollableConsumer(String name, String group, org.springframework.cloud.stream.binder.PollableSource<org.springframework.messaging.MessageHandler> inboundBindTarget, CP consumerProperties)
void	setPollableConsumerBinder(org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,CP> binder)

Methods inherited from class org.springframework.cloud.stream.binder.AbstractTestBinder

bindConsumer, bindProducer, cleanup, getBinder, getCoreBinder, setBinder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.cloud.stream.binder.Binder

getBinderIdentity

Constructor Details

AbstractPollableConsumerTestBinder

public AbstractPollableConsumerTestBinder()

Method Details

setPollableConsumerBinder

public void setPollableConsumerBinder(org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,CP> binder)

bindPollableConsumer

public org.springframework.cloud.stream.binder.Binding<org.springframework.cloud.stream.binder.PollableSource<org.springframework.messaging.MessageHandler>> bindPollableConsumer(String name,
 String group,
 org.springframework.cloud.stream.binder.PollableSource<org.springframework.messaging.MessageHandler> inboundBindTarget,
 CP consumerProperties)

Specified by:

bindPollableConsumer in interface org.springframework.cloud.stream.binder.PollableConsumerBinder<C extends org.springframework.cloud.stream.binder.AbstractBinder<org.springframework.messaging.MessageChannel,CP,PP>,CP extends org.springframework.cloud.stream.binder.ConsumerProperties>