SimpleBrokerRegistration

Registration class for configuring a {@link SimpleBrokerMessageHandler}.

@author Rossen Stoyanchev @since 4.0

Constructors

this
this(SubscribableChannel inChannel, MessageChannel outChannel, string[] prefixes)
Undocumented in source.

Members

Functions

getMessageHandler
SimpleBrokerMessageHandler getMessageHandler(SubscribableChannel brokerChannel)
Undocumented in source. Be warned that the author may not have intended to support it.
setHeartbeatValue
SimpleBrokerRegistration setHeartbeatValue(long[] heartbeat)

Configure the value for the heartbeat settings. The first number represents how often the server will write or send a heartbeat. The second is how often the client should write. 0 means no heartbeats. <p>By default this is set to "0, 0" unless the {@link #setTaskScheduler taskScheduler} in which case the default becomes "10000,10000" (in milliseconds). @since 4.2

setSelectorHeaderName
void setSelectorHeaderName(string selectorHeaderName)

Configure the name of a header that a subscription message can have for the purpose of filtering messages matched to the subscription. The header value is expected to be a Spring EL expression to be applied to the headers of messages matched to the subscription. <p>For example: <pre> headers.foo == 'bar' </pre> <p>By default this is set to "selector". You can set it to a different name, or to {@code null} to turn off support for a selector header. @param selectorHeaderName the name to use for a selector header @since 4.3.17

Inherited Members

From AbstractBrokerRegistration

getClientInboundChannel
SubscribableChannel getClientInboundChannel()
Undocumented in source. Be warned that the author may not have intended to support it.
getClientOutboundChannel
MessageChannel getClientOutboundChannel()
Undocumented in source. Be warned that the author may not have intended to support it.
getDestinationPrefixes
string[] getDestinationPrefixes()
Undocumented in source. Be warned that the author may not have intended to support it.
getMessageHandler
AbstractBrokerMessageHandler getMessageHandler(SubscribableChannel brokerChannel)
Undocumented in source.

Meta