Package com.rabbitmq.client.impl

Class HeartbeatSender

java.lang.Object

com.rabbitmq.client.impl.HeartbeatSender

final class HeartbeatSender
extends Object

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

Modifier and Type	Class	Description
private final class	HeartbeatSender.HeartbeatRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private ScheduledExecutorService	executor
private final FrameHandler	frameHandler
private ScheduledFuture<?>	future
private long	lastActivityTime
private final Object	monitor
private final boolean	privateExecutor
private boolean	shutdown
private final ThreadFactory	threadFactory

Constructor Summary

Constructors

Constructor	Description
HeartbeatSender(FrameHandler frameHandler, ScheduledExecutorService heartbeatExecutor, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
private ScheduledExecutorService	createExecutorIfNecessary()
void	setHeartbeat(int heartbeatSeconds)	Sets the heartbeat in seconds.
void	shutdown()	Shutdown the heartbeat process, if any.
void	signalActivity()

Methods inherited from class java.lang.Object

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

Field Details

monitor

private final Object monitor

frameHandler

private final FrameHandler frameHandler

threadFactory

private final ThreadFactory threadFactory

executor

private ScheduledExecutorService executor

privateExecutor

private final boolean privateExecutor

future

private ScheduledFuture<?> 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

private ScheduledExecutorService createExecutorIfNecessary()

shutdown

public void shutdown()

Shutdown the heartbeat process, if any.