Module Expr Str Import alias Import alias Import alias Import alias ImportFrom alias alias ImportFrom alias Import alias identifier Import alias identifier Assign NameStore Call AttributeLoad NameLoad attr Str ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Pass decorator_list FunctionDef arguments args NameParam defaults body Expr Str Pass decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str If CompareIn Str NameLoad body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Call AttributeLoad Call AttributeLoad SubscriptLoad NameLoad Index Str attr Str Str attr Str AttributeLoad NameLoad attr If CompareNotEq AttributeLoad NameLoad attr TupleLoad Num Num body Assign AttributeStore NameLoad attr BinOpDiv SubscriptLoad AttributeLoad NameLoad attr Index Num Num Assign AttributeStore NameLoad attr BinOpMult BinOpDiv SubscriptLoad AttributeLoad NameLoad attr Index Num Num Num If CompareNotEq AttributeLoad NameLoad attr Num body Assign AttributeStore NameLoad attr BinOpAdd Call NameLoad BinOpMult Num AttributeLoad NameLoad attr If CompareEq AttributeLoad NameLoad attr Num body Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr orelse If CompareEq AttributeLoad NameLoad attr Num body Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr orelse Assign AttributeStore NameLoad attr BinOpDiv Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num Assign AttributeStore NameLoad attr NameLoad If CompareIs AttributeLoad NameLoad attr NameLoad body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore AttributeLoad NameLoad attr attr BinOpMod Str Call NameLoad AttributeLoad NameLoad attr Str Str decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg body Expr Str Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str If BoolOpOr CompareEq AttributeLoad NameLoad attr NameLoad CompareEq AttributeLoad NameLoad attr NameLoad body If CompareNotEq AttributeLoad NameLoad attr TupleLoad Num Num body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad BinOpMod Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call NameLoad While AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call NameLoad If BoolOpAnd CompareNotEq AttributeLoad NameLoad attr Num CompareGt BinOpSub NameLoad NameLoad AttributeLoad NameLoad attr body Assign NameStore NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr NameLoad Dict NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str ExceptHandler type NameLoad body Assign TupleStore NameStore NameStore NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str NameLoad If CompareNotEq AttributeLoad NameLoad attr Num body Assign NameStore BinOpSub NameLoad AttributeLoad NameLoad attr If CompareGt NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad For NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr body Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str If BoolOpAnd CompareIn Str NameLoad CompareEq SubscriptLoad NameLoad Index Str AttributeLoad NameLoad attr body With AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str With AttributeLoad NameLoad attr body While UnaryOpNot AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam defaults body 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 Num decorator_list FunctionDef arguments args NameParam defaults body Expr Str AugAssignAdd AttributeStore NameLoad attr Num Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad AugAssignAdd AttributeStore NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str SubscriptLoad NameLoad Index Num SubscriptLoad NameLoad Index Num AttributeLoad NameLoad attr AugAssignAdd AttributeStore NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str AugAssignAdd AttributeStore NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str AugAssignAdd AttributeStore NameLoad attr Num decorator_list 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 Return BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Print BinOpMod Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Print BinOpMod Str TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Print Str decorator_list FunctionDef arguments args NameParam defaults body Print Str decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Print BinOpMod Str TupleLoad NameLoad NameLoad Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Print BinOpMod Str TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Print BinOpMod Str TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Print BinOpMod Str TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Print BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Print Str decorator_list decorator_list ClassDef bases NameLoad NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad NameLoad With AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body With AttributeLoad NameLoad attr body While UnaryOpNot AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return SubscriptLoad AttributeLoad NameLoad attr Index BinOpSub Call NameLoad AttributeLoad NameLoad attr Num decorator_list decorator_list
N/A N/A Various listeners for using with stomp.py connections.
 N/A logging N/A sys N/A threading N/A time stomp.backward gcd monotonic stomp.constants * N/A stomp.exception exception N/A stomp.utils utils N/A log N/A N/A logging getLogger stomp.py Publisher N/A object N/A N/A 
    Simply a registry of listeners.
     set_listener N/A N/A self name listener N/A N/A N/A 
        Set a named listener to use with this connection. See :py:class:`stomp.listener.ConnectionListener`

        :param name: the name of the listener
        :param listener: the listener object
         N/A N/A remove_listener N/A N/A self name N/A N/A N/A 
        Remove a listener.

        :param name: the name of the listener to remove
         N/A N/A get_listener N/A N/A self name N/A N/A N/A 
        Return the named listener.

        :param name: the listener to return
         N/A None N/A N/A ConnectionListener N/A object N/A N/A 
    This class should be used as a base class for objects registered
    using Connection.set_listener().
     on_connecting N/A N/A self host_and_port N/A N/A N/A 
        Called by the STOMP connection once a TCP/IP connection to the
        STOMP server has been established or re-established. Note that
        at this point, no connection has been established on the STOMP
        protocol level. For this, you need to invoke the "connect"
        method on the connection.

        :param host_and_port: a tuple containing the host name and port number to which the connection
            has been established.
         N/A N/A on_connected N/A N/A self headers body N/A N/A N/A 
        Called by the STOMP connection when a CONNECTED frame is
        received (after a connection has been established or
        re-established).

        :param headers: a dictionary containing all headers sent by the server as key/value pairs.
        :param body: the frame's payload. This is usually empty for CONNECTED frames.
         N/A N/A on_disconnected N/A N/A self N/A N/A N/A 
        Called by the STOMP connection when a TCP/IP connection to the
        STOMP server has been lost.  No messages should be sent via
        the connection until it has been reestablished.
         N/A N/A on_heartbeat_timeout N/A N/A self N/A N/A N/A 
        Called by the STOMP connection when a heartbeat message has not been
        received beyond the specified period.
         N/A N/A on_before_message N/A N/A self headers body N/A N/A N/A 
        Called by the STOMP connection before a message is returned to the client app. Returns a tuple
        containing the headers and body (so that implementing listeners can pre-process the content).

        :param headers: the message headers
        :param body: the message body
         N/A N/A headers body N/A on_message N/A N/A self headers body N/A N/A N/A 
        Called by the STOMP connection when a MESSAGE frame is received.

        :param headers: a dictionary containing all headers sent by the server as key/value pairs.
        :param body: the frame's payload - the message body.
         N/A N/A on_receipt N/A N/A self headers body N/A N/A N/A 
        Called by the STOMP connection when a RECEIPT frame is
        received, sent by the server if requested by the client using
        the 'receipt' header.

        :param headers: a dictionary containing all headers sent by the server as key/value pairs.
        :param body: the frame's payload. This is usually empty for RECEIPT frames.
         N/A N/A on_error N/A N/A self headers body N/A N/A N/A 
        Called by the STOMP connection when an ERROR frame is received.

        :param headers: a dictionary containing all headers sent by the server as key/value pairs.
        :param body: the frame's payload - usually a detailed error description.
         N/A N/A on_send N/A N/A self frame N/A N/A N/A 
        Called by the STOMP connection when it is in the process of sending a message

        :param frame: the frame to be sent
         N/A N/A on_heartbeat N/A N/A self N/A N/A N/A 
        Called on receipt of a heartbeat.
         N/A N/A N/A HeartbeatListener N/A ConnectionListener N/A N/A 
    Listener used to handle STOMP heartbeating.
     __init__ N/A N/A self heartbeats N/A N/A N/A N/A self running False N/A N/A self heartbeats heartbeats N/A N/A self received_heartbeat None N/A N/A self heartbeat_thread None N/A on_connected N/A N/A self headers body N/A N/A N/A 
        Once the connection is established, and 'heart-beat' is found in the headers, we calculate the real
        heartbeat numbers (based on what the server sent and what was specified by the client) - if the heartbeats
        are not 0, we start up the heartbeat loop accordingly.

        :param headers: headers in the connection message
        :param body: the message body
         N/A N/A heart-beat headers N/A N/A N/A self heartbeats N/A N/A utils calculate_heartbeats N/A N/A N/A N/A N/A headers N/A heart-beat replace split , N/A self heartbeats N/A N/A N/A self heartbeats N/A 0 0 N/A N/A N/A self send_sleep N/A N/A N/A self heartbeats N/A 0 1000 N/A N/A self receive_sleep N/A N/A N/A N/A self heartbeats N/A 1 1000 1.5 N/A N/A N/A self receive_sleep 0 N/A N/A N/A self received_heartbeat N/A N/A monotonic N/A 2 N/A self receive_sleep N/A N/A N/A self send_sleep 0 N/A N/A N/A self sleep_time N/A self receive_sleep N/A N/A N/A N/A self receive_sleep 0 N/A N/A N/A self sleep_time N/A self send_sleep N/A N/A N/A self sleep_time N/A N/A gcd N/A self send_sleep N/A self receive_sleep 2.0 N/A N/A self running True N/A N/A N/A self heartbeat_thread None N/A N/A N/A self heartbeat_thread N/A N/A utils default_create_thread N/A self __heartbeat_loop N/A N/A N/A self heartbeat_thread name N/A StompHeartbeat%s N/A getattr N/A self heartbeat_thread name Thread N/A on_disconnected N/A N/A self N/A N/A N/A N/A self running False N/A on_message N/A N/A self headers body N/A N/A N/A 
        Reset the last received time whenever a message is received.

        :param headers: headers in the message
        :param body: the message content
         N/A N/A self received_heartbeat N/A monotonic N/A on_receipt N/A N/A self N/A _ N/A N/A 
        Reset the last received time whenever a receipt is received.
         N/A N/A self received_heartbeat N/A monotonic N/A on_error N/A N/A self N/A _ N/A N/A 
        Reset the last received time whenever an error is received.
         N/A N/A self received_heartbeat N/A monotonic N/A on_heartbeat N/A N/A self N/A N/A N/A 
        Reset the last received time whenever a heartbeat message is received.
         N/A N/A self received_heartbeat N/A monotonic N/A on_send N/A N/A self frame N/A N/A N/A 
        Add the heartbeat header to the frame when connecting.

        :param frame: the Frame object
         N/A N/A N/A N/A frame cmd CMD_CONNECT N/A N/A frame cmd CMD_STOMP N/A N/A N/A N/A self heartbeats N/A 0 0 N/A N/A N/A N/A frame headers N/A HDR_HEARTBEAT N/A %s,%s N/A self heartbeats N/A __heartbeat_loop N/A N/A self N/A N/A N/A 
        Main loop for sending (and monitoring received) heartbeats.
         N/A send_time N/A monotonic N/A N/A self running N/A N/A N/A N/A time sleep N/A self sleep_time N/A now N/A monotonic N/A N/A N/A N/A self send_sleep 0 N/A N/A now send_time N/A self send_sleep N/A N/A send_time now N/A N/A N/A log debug Sending a heartbeat message at %s now N/A N/A N/A N/A N/A N/A self transport transmit N/A N/A utils Frame None N/A None N/A N/A N/A N/A exception NotConnectedException N/A N/A N/A N/A log debug Lost connection, unable to send heartbeat N/A N/A Exception N/A N/A N/A _ e _ N/A N/A sys exc_info N/A N/A N/A log debug Unable to send heartbeat, due to: %s e N/A N/A N/A self receive_sleep 0 N/A N/A diff_receive N/A now N/A self received_heartbeat N/A N/A diff_receive N/A self receive_sleep N/A N/A N/A N/A log warning Heartbeat timeout: diff_receive=%s, time=%s, lastrec=%s diff_receive now N/A self received_heartbeat N/A N/A N/A N/A self transport disconnect_socket N/A N/A N/A N/A self transport set_connected False N/A listener N/A N/A N/A N/A self transport listeners values N/A N/A N/A N/A listener on_heartbeat_timeout N/A N/A WaitingListener N/A ConnectionListener N/A N/A 
    A listener which waits for a specific receipt to arrive.
     __init__ N/A N/A self receipt N/A N/A N/A N/A self condition N/A N/A threading Condition N/A N/A self receipt receipt N/A N/A self received False N/A on_receipt N/A N/A self headers body N/A N/A N/A 
        If the receipt id can be found in the headers, then notify the waiting thread.

        :param headers: headers in the message
        :param body: the message content
         N/A N/A N/A receipt-id headers N/A N/A headers N/A receipt-id N/A self receipt N/A N/A N/A self condition N/A N/A N/A self received True N/A N/A N/A N/A self condition notify N/A wait_on_receipt N/A N/A self N/A N/A N/A 
        Wait until we receive a message receipt.
         N/A N/A self condition N/A N/A N/A N/A self received N/A N/A N/A N/A N/A self condition wait N/A N/A self received False N/A N/A StatsListener N/A ConnectionListener N/A N/A 
    A connection listener for recording statistics on messages sent and received.
     __init__ N/A N/A self N/A N/A N/A N/A self errors 0 N/A N/A self connections 0 N/A N/A self disconnects 0 N/A N/A self messages 0 N/A N/A self messages_sent 0 N/A N/A self heartbeat_timeouts 0 N/A on_disconnected N/A N/A self N/A N/A N/A 
        Increment the disconnect count. See :py:meth:`ConnectionListener.on_disconnected`
         N/A N/A self disconnects 1 N/A N/A N/A log info disconnected (x %s) N/A self disconnects N/A on_error N/A N/A self headers body N/A N/A N/A 
        Increment the error count. See :py:meth:`ConnectionListener.on_error`

        :param headers: headers in the message
        :param body: the message content
         N/A N/A N/A log info received an error %s [%s] body headers N/A N/A self errors 1 N/A on_connecting N/A N/A self host_and_port N/A N/A N/A 
        Increment the connection count. See :py:meth:`ConnectionListener.on_connecting`

        :param host_and_port: the host and port as a tuple
         N/A N/A N/A log info connecting %s %s (x %s) N/A host_and_port N/A 0 N/A host_and_port N/A 1 N/A self connections N/A N/A self connections 1 N/A on_message N/A N/A self headers body N/A N/A N/A 
        Increment the message received count. See :py:meth:`ConnectionListener.on_message`

        :param headers: headers in the message
        :param body: the message content
         N/A N/A self messages 1 N/A on_send N/A N/A self frame N/A N/A N/A 
        Increment the send count. See :py:meth:`ConnectionListener.on_send`
         N/A N/A self messages_sent 1 N/A on_heartbeat_timeout N/A N/A self N/A N/A N/A 
        Increment the heartbeat timeout. See :py:meth:`ConnectionListener.on_heartbeat_timeout`
         N/A N/A N/A log debug received heartbeat timeout N/A N/A self heartbeat_timeouts 1 N/A __str__ N/A N/A self N/A N/A N/A 
        Return a string containing the current statistics (messages sent and received,
        errors, etc)
         N/A N/A Connections: %s
Messages sent: %s
Messages received: %s
Errors: %s N/A N/A self connections N/A self messages_sent N/A self messages N/A self errors N/A N/A PrintingListener N/A ConnectionListener N/A on_connecting N/A N/A self host_and_port N/A N/A N/A N/A on_connecting %s %s host_and_port N/A on_connected N/A N/A self headers body N/A N/A N/A N/A on_connected %s %s N/A headers body N/A on_disconnected N/A N/A self N/A N/A N/A on_disconnected N/A on_heartbeat_timeout N/A N/A self N/A N/A N/A on_heartbeat_timeout N/A on_before_message N/A N/A self headers body N/A N/A N/A N/A on_before_message %s %s N/A headers body N/A N/A headers body N/A on_message N/A N/A self headers body N/A N/A N/A N/A on_message %s %s N/A headers body N/A on_receipt N/A N/A self headers body N/A N/A N/A N/A on_receipt %s %s N/A headers body N/A on_error N/A N/A self headers body N/A N/A N/A N/A on_error %s %s N/A headers body N/A on_send N/A N/A self frame N/A N/A N/A N/A on_send %s %s %s N/A N/A frame cmd N/A frame headers N/A frame body N/A on_heartbeat N/A N/A self N/A N/A N/A on_heartbeat N/A N/A TestListener N/A StatsListener WaitingListener N/A N/A 
    Implementation of StatsListener and WaitingListener. Useful for testing.
     __init__ N/A N/A self receipt N/A None N/A N/A N/A N/A StatsListener __init__ self N/A N/A N/A WaitingListener __init__ self receipt N/A N/A self message_list N/A N/A N/A self message_condition N/A N/A threading Condition N/A N/A self message_received False N/A on_message N/A N/A self headers message N/A N/A N/A N/A N/A StatsListener on_message self headers message N/A N/A N/A N/A self message_list append N/A headers message N/A N/A self message_condition N/A N/A N/A self message_received True N/A N/A N/A N/A self message_condition notify N/A wait_for_message N/A N/A self N/A N/A N/A N/A self message_condition N/A N/A N/A N/A self message_received N/A N/A N/A N/A N/A self message_condition wait N/A N/A self message_received False N/A get_latest_message N/A N/A self N/A N/A N/A N/A N/A self message_list N/A N/A N/A len N/A self message_list 1 N/A N/A