public class StompBrokerRelayMessageHandler extends Object implements MessageHandler, SmartLifecycle
| Constructor and Description |
|---|
StompBrokerRelayMessageHandler(MessageChannel messageChannel,
Collection<String> destinationPrefixes) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
checkDestinationPrefix(StompCommand command,
String destination) |
String[] |
getDestinationPrefixes() |
int |
getPhase()
Return the phase value of this object.
|
String |
getRelayHost() |
int |
getRelayPort() |
String |
getSystemLogin() |
String |
getSystemPasscode() |
void |
handleMessage(Message<?> message)
Handles the message if possible.
|
boolean |
isAutoStartup()
Return whether this Lifecycle component should be started automatically
by the container when the ApplicationContext is refreshed.
|
boolean |
isRunning()
Check whether this component is currently running.
|
void |
setRelayHost(String relayHost)
Set the STOMP message broker host.
|
void |
setRelayPort(int relayPort)
Set the STOMP message broker port.
|
void |
setSystemLogin(String systemLogin)
Set the login for a "system" TCP connection used to send messages to the STOMP
broker without having a client session (e.g.
|
void |
setSystemPasscode(String systemPasscode)
Set the passcode for a "system" TCP connection used to send messages to the STOMP
broker without having a client session (e.g.
|
void |
start()
Start this component.
|
void |
stop()
Stop this component, typically in a synchronous fashion, such that
the component is fully stopped upon return of this method.
|
void |
stop(Runnable callback)
Indicates that a Lifecycle component must stop if it is currently running.
|
public StompBrokerRelayMessageHandler(MessageChannel messageChannel, Collection<String> destinationPrefixes)
messageChannel - the channel to send messages from the STOMP broker todestinationPrefixes - the broker supported destination prefixes; destinations
that do not match the given prefix are ignored.public void setRelayHost(String relayHost)
public String getRelayHost()
public void setRelayPort(int relayPort)
public int getRelayPort()
public void setSystemLogin(String systemLogin)
public String getSystemLogin()
public void setSystemPasscode(String systemPasscode)
public String getSystemPasscode()
public String[] getDestinationPrefixes()
public boolean isAutoStartup()
SmartLifecycleisAutoStartup in interface SmartLifecyclepublic int getPhase()
Phasedpublic boolean isRunning()
LifecycleIn the case of a container, this will return true
only if all components that apply are currently running.
public void start()
LifecycleIn the case of a container, this will propagate the start signal to all components that apply.
public void stop()
LifecycleSmartLifecycle and its stop(Runnable)
variant in cases where asynchronous stop behavior is necessary.
Should not throw an exception if the component isn't started yet.
In the case of a container, this will propagate the stop signal to all components that apply.
stop in interface LifecycleSmartLifecycle.stop(Runnable)public void stop(Runnable callback)
SmartLifecycleThe provided callback is used by the LifecycleProcessor to support an
ordered, and potentially concurrent, shutdown of all components having a
common shutdown order value. The callback must be executed after
the SmartLifecycle component does indeed stop.
The LifecycleProcessor will call only this variant of the
stop method; i.e. Lifecycle.stop() will not be called for
SmartLifecycle implementations unless explicitly delegated to within
this method.
stop in interface SmartLifecyclepublic void handleMessage(Message<?> message)
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 messageprotected boolean checkDestinationPrefix(StompCommand command, String destination)