protected void |
AbstractMessageChannelBinder.afterUnbindConsumer(ConsumerDestination destination,
String group,
C consumerProperties) |
Invoked after the unbinding of a consumer.
|
protected abstract org.springframework.integration.core.MessageProducer |
AbstractMessageChannelBinder.createConsumerEndpoint(ConsumerDestination destination,
String group,
C properties) |
Creates MessageProducer that receives data from the consumer destination.
|
protected AbstractMessageChannelBinder.PolledConsumerResources |
AbstractMessageChannelBinder.createPolledConsumerResources(String name,
String group,
ConsumerDestination destination,
C consumerProperties) |
|
protected String |
AbstractMessageChannelBinder.errorsBaseName(ConsumerDestination destination,
String group,
C consumerProperties) |
|
protected String |
AbstractMessageChannelBinder.getErrorBridgeName(ConsumerDestination destination,
String group,
C consumerProperties) |
|
protected org.springframework.messaging.MessageHandler |
AbstractMessageChannelBinder.getErrorMessageHandler(ConsumerDestination destination,
String group,
C consumerProperties) |
Binders can return a message handler to be subscribed to the error channel.
|
protected String |
AbstractMessageChannelBinder.getErrorMessageHandlerName(ConsumerDestination destination,
String group,
C consumerProperties) |
|
protected String |
AbstractMessageChannelBinder.getErrorRecovererName(ConsumerDestination destination,
String group,
C consumerProperties) |
|
protected org.springframework.messaging.MessageHandler |
AbstractMessageChannelBinder.getPolledConsumerErrorMessageHandler(ConsumerDestination destination,
String group,
C consumerProperties) |
Binders can return a message handler to be subscribed to the error channel.
|
protected AbstractMessageChannelBinder.ErrorInfrastructure |
AbstractMessageChannelBinder.registerErrorInfrastructure(ConsumerDestination destination,
String group,
C consumerProperties) |
Build an errorChannelRecoverer that writes to a pub/sub channel for the destination
when an exception is thrown to a consumer.
|
protected AbstractMessageChannelBinder.ErrorInfrastructure |
AbstractMessageChannelBinder.registerErrorInfrastructure(ConsumerDestination destination,
String group,
C consumerProperties,
boolean polled) |
Build an errorChannelRecoverer that writes to a pub/sub channel for the destination
when an exception is thrown to a consumer.
|