Modifier and Type | Method and Description |
---|---|
protected Class<? extends ChannelMessageConsumer> |
CustomisableSdkModule.provideMessageConsumerImplementationClass()
Binds the message receiver that should be used to process received messages
|
Modifier and Type | Class and Description |
---|---|
class |
ChannelMessageConsumerImpl
A basic implementation of the
ChannelMessageConsumer interface |
Modifier and Type | Method and Description |
---|---|
void |
RabbitMqChannelImpl.open(List<String> routingKeys,
ChannelMessageConsumer channelMessageConsumer,
String messageInterest)
Opens the current channel and binds the created queue to the provided routing keys
|
void |
OnDemandChannelSupervisor.open(List<String> routingKeys,
ChannelMessageConsumer channelMessageConsumer,
String messageInterest)
Opens the current channel and binds the created queue to the provided routing keys
|
OpeningResult |
ChannelSupervisor.openChannel(List<String> routingKeys,
ChannelMessageConsumer channelMessageConsumer,
String messageInterest) |
OpeningResult |
ChannelSupervisionScheduler.openChannel(List<String> routingKeys,
ChannelMessageConsumer messageConsumer,
String messageInterest) |
Copyright © 2016–2025. All rights reserved.