public interface ChannelConfig extends ConsumerConfig
Channel
related configuration.Modifier and Type | Method and Description |
---|---|
Collection<ChannelListener> |
getChannelListeners()
Returns the channel's listeners else empty list if none were configured.
|
RecoveryPolicy |
getChannelRecoveryPolicy()
Returns the channel's recovery policy.
|
RetryPolicy |
getChannelRetryPolicy()
Returns the channel's retry policy.
|
boolean |
isExchangeRecoveryEnabled()
Returns whether exchange and exchange binding recovery is enabled.
|
boolean |
isQueueRecoveryEnabled()
Returns whether queue and queue binding recovery is enabled.
|
ChannelConfig |
withChannelListeners(ChannelListener... channelListeners)
Sets the
channelListeners to call on channel related events. |
ChannelConfig |
withChannelRecoveryPolicy(RecoveryPolicy recoveryPolicy)
Sets the
recoveryPolicy to use for recovering the channel. |
ChannelConfig |
withChannelRetryPolicy(RetryPolicy retryPolicy)
Sets the
retryPolicy to use for retrying failed invocations on the channel. |
ConsumerConfig |
withExchangeRecovery(boolean enabled)
Sets whether exchange and exchange binding recovery is enabled or not.
|
ConsumerConfig |
withQueueRecovery(boolean enabled)
Sets whether queue and queue binding recovery is enabled or not.
|
getConsumerListeners, isConsumerRecoveryEnabled, withConsumerListeners, withConsumerRecovery
Collection<ChannelListener> getChannelListeners()
withChannelListeners(ChannelListener...)
RecoveryPolicy getChannelRecoveryPolicy()
RetryPolicy getChannelRetryPolicy()
withChannelRetryPolicy(RetryPolicy)
boolean isExchangeRecoveryEnabled()
Channel.exchangeDelete(String)
.
Defaults to true when channel recovery is configured.
withExchangeRecovery(boolean)
boolean isQueueRecoveryEnabled()
Channel.queueDelete(String)
.
Defaults to true when channel recovery is configured.
withQueueRecovery(boolean)
ChannelConfig withChannelListeners(ChannelListener... channelListeners)
channelListeners
to call on channel related events.ChannelConfig withChannelRecoveryPolicy(RecoveryPolicy recoveryPolicy)
recoveryPolicy
to use for recovering the channel.ChannelConfig withChannelRetryPolicy(RetryPolicy retryPolicy)
retryPolicy
to use for retrying failed invocations on the channel.ConsumerConfig withExchangeRecovery(boolean enabled)
Channel.exchangeDelete(String)
.ConsumerConfig withQueueRecovery(boolean enabled)
Channel.queueDelete(String)
.Copyright © 2016. All rights reserved.