public class SimpleBrokerRegistration extends AbstractBrokerRegistration
SimpleBrokerMessageHandler
.Constructor and Description |
---|
SimpleBrokerRegistration(SubscribableChannel inChannel,
MessageChannel outChannel,
String[] prefixes) |
Modifier and Type | Method and Description |
---|---|
protected SimpleBrokerMessageHandler |
getMessageHandler(SubscribableChannel brokerChannel) |
SimpleBrokerRegistration |
setHeartbeatValue(long[] heartbeat)
Configure the value for the heartbeat settings.
|
SimpleBrokerRegistration |
setTaskScheduler(TaskScheduler taskScheduler)
Configure the
TaskScheduler to
use for providing heartbeat support. |
getClientInboundChannel, getClientOutboundChannel, getDestinationPrefixes
public SimpleBrokerRegistration(SubscribableChannel inChannel, MessageChannel outChannel, String[] prefixes)
public SimpleBrokerRegistration setTaskScheduler(TaskScheduler taskScheduler)
TaskScheduler
to
use for providing heartbeat support. Setting this property also sets the
heartbeatValue
to "10000, 10000".
By default this is not set.
public SimpleBrokerRegistration setHeartbeatValue(long[] heartbeat)
By default this is set to "0, 0" unless the taskScheduler
in which case the default becomes "10000,10000"
(in milliseconds).
protected SimpleBrokerMessageHandler getMessageHandler(SubscribableChannel brokerChannel)
getMessageHandler
in class AbstractBrokerRegistration