public class SimpleBrokerMessageHandler extends Object implements MessageHandler
| Constructor and Description |
|---|
SimpleBrokerMessageHandler(MessageChannel messageChannel) |
| Modifier and Type | Method and Description |
|---|---|
List<String> |
getDestinationPrefixes() |
SubscriptionRegistry |
getSubscriptionRegistry() |
void |
handleMessage(Message<?> message)
Handles the message if possible.
|
protected void |
sendMessageToSubscribers(String destination,
Message<?> message) |
void |
setDestinationPrefixes(List<String> destinationPrefixes) |
void |
setSubscriptionRegistry(SubscriptionRegistry subscriptionRegistry) |
public SimpleBrokerMessageHandler(MessageChannel messageChannel)
messageChannel - the channel to broadcast messages topublic void setSubscriptionRegistry(SubscriptionRegistry subscriptionRegistry)
public SubscriptionRegistry getSubscriptionRegistry()
public void handleMessage(Message<?> message) throws MessagingException
MessageHandlerMessageRejectedException e.g.
in case of a Selective Consumer. When a consumer tries to handle a
message, but fails to do so, a MessageHandlingException is
thrown. In the last case it is recommended to treat the message as tainted
and go into an error scenario.
When the handling results in a failure of another message being sent
(e.g. a "reply" message), that failure will trigger a
MessageDeliveryException.
handleMessage in interface MessageHandlermessage - the message to be handled
reply related to the handling of the messageMessagingException