org.springframework.messaging.simp.config

Class StompBrokerRelayRegistration

java.lang.Object

org.springframework.messaging.simp.config.AbstractBrokerRegistration

org.springframework.messaging.simp.config.StompBrokerRelayRegistration

public class StompBrokerRelayRegistration
extends AbstractBrokerRegistration

Registration class for configuring a StompBrokerRelayMessageHandler.

Since:

4.0

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor and Description
StompBrokerRelayRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, String[] destinationPrefixes)

Method Summary

Modifier and Type	Method and Description
protected StompBrokerRelayMessageHandler	getMessageHandler(SubscribableChannel brokerChannel)
StompBrokerRelayRegistration	setApplicationLogin(String login) Set the login for the "system" relay session used to send messages to the STOMP broker without having a client session (e.g.
StompBrokerRelayRegistration	setApplicationPasscode(String passcode) Set the passcode for the "system" relay session used to send messages to the STOMP broker without having a client session (e.g.
StompBrokerRelayRegistration	setAutoStartup(boolean autoStartup) Configure whether the StompBrokerRelayMessageHandler should start automatically when the Spring ApplicationContext is refreshed.
StompBrokerRelayRegistration	setRelayHost(String relayHost) Set the STOMP message broker host.
StompBrokerRelayRegistration	setRelayPort(int relayPort) Set the STOMP message broker port.
StompBrokerRelayRegistration	setSystemHeartbeatReceiveInterval(long heartbeatReceiveInterval) Set the maximum interval, in milliseconds, at which the "system" relay session expects, in the absence of any other data, to receive a heartbeat from the STOMP broker.
StompBrokerRelayRegistration	setSystemHeartbeatSendInterval(long systemHeartbeatSendInterval) Set the interval, in milliseconds, at which the "system" relay session will, in the absence of any other data being sent, send a heartbeat to the STOMP broker.

Methods inherited from class org.springframework.messaging.simp.config.AbstractBrokerRegistration

getClientInboundChannel, getClientOutboundChannel, getDestinationPrefixes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StompBrokerRelayRegistration

public StompBrokerRelayRegistration(SubscribableChannel clientInboundChannel,
                                    MessageChannel clientOutboundChannel,
                                    String[] destinationPrefixes)

Method Detail

setRelayHost

public StompBrokerRelayRegistration setRelayHost(String relayHost)

Set the STOMP message broker host.

setRelayPort

public StompBrokerRelayRegistration setRelayPort(int relayPort)

Set the STOMP message broker port.

setApplicationLogin

public StompBrokerRelayRegistration setApplicationLogin(String login)

Set the login for the "system" relay session used to send messages to the STOMP broker without having a client session (e.g. REST/HTTP request handling method).

setApplicationPasscode

public StompBrokerRelayRegistration setApplicationPasscode(String passcode)

Set the passcode for the "system" relay session used to send messages to the STOMP broker without having a client session (e.g. REST/HTTP request handling method).

setSystemHeartbeatSendInterval

public StompBrokerRelayRegistration setSystemHeartbeatSendInterval(long systemHeartbeatSendInterval)

Set the interval, in milliseconds, at which the "system" relay session will, in the absence of any other data being sent, send a heartbeat to the STOMP broker. A value of zero will prevent heartbeats from being sent to the broker.

The default value is 10000.

setSystemHeartbeatReceiveInterval

public StompBrokerRelayRegistration setSystemHeartbeatReceiveInterval(long heartbeatReceiveInterval)

Set the maximum interval, in milliseconds, at which the "system" relay session expects, in the absence of any other data, to receive a heartbeat from the STOMP broker. A value of zero will configure the relay session to expect not to receive heartbeats from the broker.

The default value is 10000.

setAutoStartup

public StompBrokerRelayRegistration setAutoStartup(boolean autoStartup)

Configure whether the StompBrokerRelayMessageHandler should start automatically when the Spring ApplicationContext is refreshed.

The default setting is true.

getMessageHandler

protected StompBrokerRelayMessageHandler getMessageHandler(SubscribableChannel brokerChannel)

Specified by:

getMessageHandler in class AbstractBrokerRegistration