public class SimpleBrokerRegistration extends AbstractBrokerRegistration
SimpleBrokerMessageHandler
.Modifier and Type | Field and Description |
---|---|
private long[] |
heartbeat |
private TaskScheduler |
taskScheduler |
Constructor and Description |
---|
SimpleBrokerRegistration(SubscribableChannel inChannel,
MessageChannel outChannel,
java.lang.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
@Nullable private TaskScheduler taskScheduler
@Nullable private long[] heartbeat
public SimpleBrokerRegistration(SubscribableChannel inChannel, MessageChannel outChannel, java.lang.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