public class SimpleBrokerMessageHandler extends AbstractBrokerMessageHandler
logger| Constructor and Description |
|---|
SimpleBrokerMessageHandler(MessageChannel messageChannel,
Collection<String> destinationPrefixes) |
| Modifier and Type | Method and Description |
|---|---|
MessageChannel |
getMessageChannel() |
SubscriptionRegistry |
getSubscriptionRegistry() |
protected void |
handleMessageInternal(Message<?> message) |
protected void |
sendMessageToSubscribers(String destination,
Message<?> message) |
void |
setSubscriptionRegistry(SubscriptionRegistry subscriptionRegistry) |
void |
startInternal() |
void |
stopInternal() |
checkDestinationPrefix, getApplicationEventPublisher, getDestinationPrefixes, getPhase, handleMessage, isAutoStartup, isRunning, publishBrokerAvailableEvent, publishBrokerUnavailableEvent, setApplicationEventPublisher, setAutoStartup, start, stop, stoppublic SimpleBrokerMessageHandler(MessageChannel messageChannel, Collection<String> destinationPrefixes)
messageChannel - the channel to broadcast messages topublic MessageChannel getMessageChannel()
public void setSubscriptionRegistry(SubscriptionRegistry subscriptionRegistry)
public SubscriptionRegistry getSubscriptionRegistry()
public void startInternal()
startInternal in class AbstractBrokerMessageHandlerpublic void stopInternal()
stopInternal in class AbstractBrokerMessageHandlerprotected void handleMessageInternal(Message<?> message)
handleMessageInternal in class AbstractBrokerMessageHandler