Class AMQConnection.MainLoop

java.lang.Object
com.rabbitmq.client.impl.AMQConnection.MainLoop
All Implemented Interfaces:
Runnable
Enclosing class:
AMQConnection

private class AMQConnection.MainLoop extends Object implements Runnable
  • Constructor Details

    • MainLoop

      private MainLoop()
  • Method Details

    • run

      public void run()
      Channel reader thread main loop. Reads a frame, and if it is not a heartbeat frame, dispatches it to the channel it refers to. Continues running until the "running" flag is set false by shutdown().
      Specified by:
      run in interface Runnable