Module Expr Str Import alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad ClassDef bases NameLoad body Expr Str Assign NameStore Num Assign NameStore Num Assign NameStore Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return CompareIs AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return AttributeLoad AttributeLoad NameLoad attr attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return CompareGtE AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str AugAssignAdd AttributeStore NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Return Call AttributeLoad NameLoad attr If UnaryOpNot AttributeLoad NameLoad attr body AugAssignAdd AttributeStore NameLoad attr Num orelse Assign AttributeStore NameLoad attr Num Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Assign NameStore BinOpMult AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore BinOpMod AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return UnaryOpNot CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args defaults body Expr Str Return Call AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr AugAssignAdd AttributeStore NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list decorator_list
N/A N/A Handle AMQP Heartbeats N/A logging pika frame N/A LOGGER N/A N/A logging getLogger __name__ HeartbeatChecker N/A object N/A N/A Checks to make sure that our heartbeat is received at the expected
    intervals.

     N/A MAX_IDLE_COUNT 2 N/A _CONNECTION_FORCED 320 N/A _STALE_CONNECTION Too Many Missed Heartbeats, No reply in %i seconds __init__ N/A N/A self connection interval idle_count N/A MAX_IDLE_COUNT N/A N/A Create a heartbeat on connection sending a heartbeat frame every
        interval seconds.

        :param pika.connection.Connection: Connection object
        :param int interval: Heartbeat check interval
        :param int idle_count: Number of heartbeat intervals missed until the
                               connection is considered idle and disconnects

         N/A N/A self _connection connection N/A N/A self _interval interval N/A N/A self _max_idle_count idle_count N/A N/A self _bytes_received 0 N/A N/A self _bytes_sent 0 N/A N/A self _heartbeat_frames_received 0 N/A N/A self _heartbeat_frames_sent 0 N/A N/A self _idle_byte_intervals 0 N/A N/A self _timer None N/A N/A N/A self _setup_timer N/A active N/A N/A self N/A N/A N/A Return True if the connection's heartbeat attribute is set to this
        instance.

        :rtype True

         N/A N/A N/A N/A self _connection heartbeat self N/A property bytes_received_on_connection N/A N/A self N/A N/A N/A Return the number of bytes received by the connection bytes object.

        :rtype int

         N/A N/A N/A self _connection bytes_received N/A property connection_is_idle N/A N/A self N/A N/A N/A Returns true if the byte count hasn't changed in enough intervals
        to trip the max idle threshold.

         N/A N/A N/A self _idle_byte_intervals N/A self _max_idle_count N/A property received N/A N/A self N/A N/A N/A Called when a heartbeat is received N/A N/A N/A LOGGER debug Received heartbeat frame N/A N/A self _heartbeat_frames_received 1 N/A send_and_check N/A N/A self N/A N/A N/A Invoked by a timer to send a heartbeat when we need to, check to see
        if we've missed any heartbeats and disconnect our connection if it's
        been idle too long.

         N/A N/A N/A LOGGER debug Received %i heartbeat frames, sent %i N/A self _heartbeat_frames_received N/A self _heartbeat_frames_sent N/A N/A self connection_is_idle N/A N/A N/A N/A self _close_connection N/A N/A N/A self _has_received_data N/A N/A N/A self _idle_byte_intervals 1 N/A N/A N/A self _idle_byte_intervals 0 N/A N/A N/A self _update_counters N/A N/A N/A self _send_heartbeat_frame N/A N/A N/A self _start_timer N/A stop N/A N/A self N/A N/A N/A Stop the heartbeat checker N/A N/A self _timer N/A N/A N/A N/A LOGGER debug Removing timeout for next heartbeat interval N/A N/A N/A N/A self _connection remove_timeout N/A self _timer N/A N/A self _timer None N/A _close_connection N/A N/A self N/A N/A N/A Close the connection with the AMQP Connection-Forced value. N/A N/A N/A LOGGER info Connection is idle, %i stale byte intervals N/A self _idle_byte_intervals N/A duration N/A N/A self _max_idle_count N/A self _interval N/A text N/A N/A HeartbeatChecker _STALE_CONNECTION duration N/A N/A N/A N/A self _connection close N/A HeartbeatChecker _CONNECTION_FORCED text N/A N/A N/A N/A self _connection _on_terminate N/A HeartbeatChecker _CONNECTION_FORCED text N/A _has_received_data N/A N/A self N/A N/A N/A Returns True if the connection has received data on the connection.

        :rtype: bool

         N/A N/A N/A N/A self _bytes_received N/A self bytes_received_on_connection N/A property _new_heartbeat_frame N/A N/A N/A N/A N/A Return a new heartbeat frame.

        :rtype pika.frame.Heartbeat

         N/A N/A N/A frame Heartbeat N/A staticmethod _send_heartbeat_frame N/A N/A self N/A N/A N/A Send a heartbeat frame on the connection.

         N/A N/A N/A LOGGER debug Sending heartbeat frame N/A N/A N/A N/A self _connection _send_frame N/A N/A self _new_heartbeat_frame N/A N/A self _heartbeat_frames_sent 1 N/A _setup_timer N/A N/A self N/A N/A N/A Use the connection objects delayed_call function which is
        implemented by the Adapter for calling the check_heartbeats function
        every interval seconds.

         N/A N/A self _timer N/A N/A N/A self _connection add_timeout N/A self _interval N/A self send_and_check N/A _start_timer N/A N/A self N/A N/A N/A If the connection still has this object set for heartbeats, add a
        new timer.

         N/A N/A self active N/A N/A N/A N/A self _setup_timer N/A _update_counters N/A N/A self N/A N/A N/A Update the internal counters for bytes sent and received and the
        number of frames received

         N/A N/A self _bytes_sent N/A N/A self _connection bytes_sent N/A N/A self _bytes_received N/A N/A self _connection bytes_received N/A N/A