Package com.rabbitmq.client.impl
Class HeartbeatSender
java.lang.Object
com.rabbitmq.client.impl.HeartbeatSender
Manages heartbeat sending for a
AMQConnection
.
Heartbeats are sent in a dedicated thread that is separate
from the main loop thread used for the connection.-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate ScheduledExecutorService
private final FrameHandler
private ScheduledFuture
<?> private long
private final Object
private final boolean
private boolean
private final ThreadFactory
-
Constructor Summary
ConstructorsConstructorDescriptionHeartbeatSender
(FrameHandler frameHandler, ScheduledExecutorService heartbeatExecutor, ThreadFactory threadFactory) -
Method Summary
Modifier and TypeMethodDescriptionprivate ScheduledExecutorService
void
setHeartbeat
(int heartbeatSeconds) Sets the heartbeat in seconds.void
shutdown()
Shutdown the heartbeat process, if any.void
-
Field Details
-
monitor
-
frameHandler
-
threadFactory
-
executor
-
privateExecutor
private final boolean privateExecutor -
future
-
shutdown
private boolean shutdown -
lastActivityTime
private volatile long lastActivityTime
-
-
Constructor Details
-
HeartbeatSender
HeartbeatSender(FrameHandler frameHandler, ScheduledExecutorService heartbeatExecutor, ThreadFactory threadFactory)
-
-
Method Details
-
signalActivity
public void signalActivity() -
setHeartbeat
public void setHeartbeat(int heartbeatSeconds) Sets the heartbeat in seconds. -
createExecutorIfNecessary
-
shutdown
public void shutdown()Shutdown the heartbeat process, if any.
-