Package | Description |
---|---|
org.springframework.cloud.stream.binder |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
protected org.springframework.retry.RecoveryCallback<Object> |
AbstractMessageChannelBinder.getPolledConsumerRecoveryCallback(AbstractMessageChannelBinder.ErrorInfrastructure errorInfrastructure,
C properties)
Implementations can override the default
ErrorMessageSendingRecoverer . |
Constructor and Description |
---|
PolledConsumerResources(org.springframework.integration.core.MessageSource<?> source,
AbstractMessageChannelBinder.ErrorInfrastructure errorInfrastructure) |
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.