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.

  • 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

  • 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.