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, stop
public 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 AbstractBrokerMessageHandler
public void stopInternal()
stopInternal
in class AbstractBrokerMessageHandler
protected void handleMessageInternal(Message<?> message)
handleMessageInternal
in class AbstractBrokerMessageHandler