Module Expr Str Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad ClassDef bases AttributeLoad NameLoad attr body Expr Str Assign NameStore Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Str attr NameLoad Return BinOpAdd BinOpAdd Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr Call NameLoad NameLoad NameLoad Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Raise NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Num Call AttributeLoad NameLoad attr Str AttributeLoad AttributeLoad NameLoad attr attr Return Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr Num Call AttributeLoad NameLoad attr Str AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr ListLoad AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Str FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr Call NameLoad decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr body Expr Str Assign NameStore Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad body Expr Str Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr BoolOpOr NameLoad SubscriptLoad AttributeLoad NameLoad attr Index Num Assign AttributeStore NameLoad attr BoolOpOr NameLoad SubscriptLoad AttributeLoad NameLoad attr Index Num Assign AttributeStore NameLoad attr BoolOpOr NameLoad SubscriptLoad AttributeLoad NameLoad attr Index Num decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return BinOpAdd Str Call AttributeLoad NameLoad attr Str Num AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list FunctionDef arguments args NameParam defaults body Expr Str TryExcept body If CompareEq SubscriptLoad NameLoad Slice Num Num Str body Assign TupleStore NameStore NameStore NameStore Call AttributeLoad NameLoad attr Str NameLoad Num Return TupleLoad Num Call NameLoad NameLoad NameLoad NameLoad handlers ExceptHandler type TupleLoad NameLoad AttributeLoad NameLoad attr body Return TupleLoad Num NameLoad TryExcept body Assign TupleStore NameStore NameStore NameStore Call AttributeLoad NameLoad attr Str SubscriptLoad NameLoad Slice Num Num handlers ExceptHandler type AttributeLoad NameLoad attr body Return TupleLoad Num NameLoad Assign NameStore BinOpAdd BinOpAdd AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr If CompareGt NameLoad Call NameLoad NameLoad body Return TupleLoad Num NameLoad If CompareNotEq SubscriptLoad NameLoad Slice BinOpSub NameLoad Num NameLoad Call NameLoad AttributeLoad NameLoad attr body Raise Call AttributeLoad NameLoad attr Str Assign NameStore SubscriptLoad NameLoad Slice AttributeLoad NameLoad attr BinOpSub NameLoad Num If CompareEq NameLoad AttributeLoad NameLoad attr body Assign NameStore SubscriptLoad Call AttributeLoad NameLoad attr Str NameLoad Index Num Assign NameStore Call SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Num Return TupleLoad NameLoad Call NameLoad NameLoad NameLoad orelse If CompareEq NameLoad AttributeLoad NameLoad attr body Assign TupleStore NameStore NameStore NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Assign NameStore Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Slice Num Return TupleLoad NameLoad Call NameLoad NameLoad NameLoad NameLoad orelse If CompareEq NameLoad AttributeLoad NameLoad attr body Return TupleLoad NameLoad Call NameLoad NameLoad NameLoad orelse If CompareEq NameLoad AttributeLoad NameLoad attr body Return TupleLoad NameLoad Call NameLoad Raise Call AttributeLoad NameLoad attr BinOpMod Str NameLoad decorator_list
N/A N/A Frame objects that do the frame demarshaling and marshaling. N/A logging N/A struct pika amqp_object pika exceptions pika spec pika.compat byte N/A LOGGER N/A N/A logging getLogger __name__ Frame N/A N/A amqp_object AMQPObject N/A N/A Base Frame object mapping. Defines a behavior for all child classes for
    assignment of core attributes and implementation of the a core _marshal
    method which child classes use to create the binary AMQP frame.

     N/A NAME Frame __init__ N/A N/A self frame_type channel_number N/A N/A N/A Create a new instance of a frame

        :param int frame_type: The frame type
        :param int channel_number: The channel number for the frame

         N/A N/A self frame_type frame_type N/A N/A self channel_number channel_number N/A _marshal N/A N/A self pieces N/A N/A N/A Create the full AMQP wire protocol frame data representation

        :rtype: bytes

         N/A payload N/A N/A join pieces N/A N/A N/A N/A N/A struct pack >BHI N/A self frame_type N/A self channel_number N/A len payload payload N/A byte N/A spec FRAME_END N/A marshal N/A N/A self N/A N/A N/A To be ended by child classes

        :raises NotImplementedError

         N/A NotImplementedError N/A N/A Method N/A Frame N/A N/A Base Method frame object mapping. AMQP method frames are mapped on top
    of this class for creating or accessing their data and attributes.

     N/A NAME METHOD __init__ N/A N/A self channel_number method N/A N/A N/A Create a new instance of a frame

        :param int channel_number: The frame type
        :param pika.Spec.Class.Method method: The AMQP Class.Method

         N/A N/A N/A Frame __init__ self N/A spec FRAME_METHOD channel_number N/A N/A self method method N/A marshal N/A N/A self N/A N/A N/A Return the AMQP binary encoded value of the frame

        :rtype: str

         N/A pieces N/A N/A N/A self method encode N/A N/A N/A pieces insert 0 N/A N/A struct pack >I N/A N/A self method INDEX N/A N/A N/A self _marshal pieces N/A N/A Header N/A Frame N/A N/A Header frame object mapping. AMQP content header frames are mapped
    on top of this class for creating or accessing their data and attributes.

     N/A NAME Header __init__ N/A N/A self channel_number body_size props N/A N/A N/A Create a new instance of a AMQP ContentHeader object

        :param int channel_number: The channel number for the frame
        :param int body_size: The number of bytes for the body
        :param pika.spec.BasicProperties props: Basic.Properties object

         N/A N/A N/A Frame __init__ self N/A spec FRAME_HEADER channel_number N/A N/A self body_size body_size N/A N/A self properties props N/A marshal N/A N/A self N/A N/A N/A Return the AMQP binary encoded value of the frame

        :rtype: str

         N/A pieces N/A N/A N/A self properties encode N/A N/A N/A pieces insert 0 N/A N/A struct pack >HxxQ N/A N/A self properties INDEX N/A self body_size N/A N/A N/A self _marshal pieces N/A N/A Body N/A Frame N/A N/A Body frame object mapping class. AMQP content body frames are mapped on
    to this base class for getting/setting of attributes/data.

     N/A NAME Body __init__ N/A N/A self channel_number fragment N/A N/A N/A 
        Parameters:

        - channel_number: int
        - fragment: unicode or str
         N/A N/A N/A Frame __init__ self N/A spec FRAME_BODY channel_number N/A N/A self fragment fragment N/A marshal N/A N/A self N/A N/A N/A Return the AMQP binary encoded value of the frame

        :rtype: str

         N/A N/A N/A self _marshal N/A N/A self fragment N/A N/A Heartbeat N/A Frame N/A N/A Heartbeat frame object mapping class. AMQP Heartbeat frames are mapped
    on to this class for a common access structure to the attributes/data
    values.

     N/A NAME Heartbeat __init__ N/A N/A self N/A N/A N/A Create a new instance of the Heartbeat frame N/A N/A N/A Frame __init__ self N/A spec FRAME_HEARTBEAT 0 N/A marshal N/A N/A self N/A N/A N/A Return the AMQP binary encoded value of the frame

        :rtype: str

         N/A N/A N/A self _marshal N/A list N/A N/A ProtocolHeader N/A N/A amqp_object AMQPObject N/A N/A AMQP Protocol header frame class which provides a pythonic interface
    for creating AMQP Protocol headers

     N/A NAME ProtocolHeader __init__ N/A N/A self major minor revision N/A None None None N/A N/A Construct a Protocol Header frame object for the specified AMQP
        version

        :param int major: Major version number
        :param int minor: Minor version number
        :param int revision: Revision

         N/A N/A self frame_type -1 N/A N/A self major N/A major N/A N/A spec PROTOCOL_VERSION N/A 0 N/A N/A self minor N/A minor N/A N/A spec PROTOCOL_VERSION N/A 1 N/A N/A self revision N/A revision N/A N/A spec PROTOCOL_VERSION N/A 2 N/A marshal N/A N/A self N/A N/A N/A Return the full AMQP wire protocol frame data representation of the
        ProtocolHeader frame

        :rtype: str

         N/A N/A AMQP N/A N/A struct pack BBBB 0 N/A self major N/A self minor N/A self revision N/A N/A decode_frame N/A N/A data_in N/A N/A N/A Receives raw socket data and attempts to turn it into a frame.
    Returns bytes used to make the frame and the frame

    :param str data_in: The raw data stream
    :rtype: tuple(bytes consumed, frame)
    :raises: pika.exceptions.InvalidFrameError

     N/A N/A N/A N/A N/A data_in N/A 0 4 AMQP N/A N/A N/A major minor revision N/A N/A struct unpack_from BBB data_in 5 N/A N/A 8 N/A ProtocolHeader major minor revision N/A N/A N/A N/A IndexError N/A struct error N/A N/A N/A 0 None N/A N/A N/A N/A frame_type channel_number frame_size N/A N/A struct unpack >BHL N/A data_in N/A 0 7 N/A N/A N/A N/A struct error N/A N/A N/A 0 None N/A frame_end N/A N/A N/A spec FRAME_HEADER_SIZE frame_size N/A spec FRAME_END_SIZE N/A N/A frame_end N/A len data_in N/A N/A N/A 0 None N/A N/A N/A data_in N/A N/A frame_end 1 frame_end N/A byte N/A spec FRAME_END N/A N/A N/A N/A exceptions InvalidFrameError Invalid FRAME_END marker N/A frame_data N/A data_in N/A N/A spec FRAME_HEADER_SIZE N/A frame_end 1 N/A N/A frame_type N/A spec FRAME_METHOD N/A N/A method_id N/A N/A N/A struct unpack_from >I frame_data N/A 0 N/A method N/A N/A N/A spec methods N/A method_id N/A N/A N/A method decode frame_data 4 N/A N/A frame_end N/A Method channel_number method N/A N/A N/A frame_type N/A spec FRAME_HEADER N/A N/A N/A class_id weight body_size N/A N/A struct unpack_from >HHQ frame_data N/A properties N/A N/A N/A spec props N/A class_id N/A out N/A N/A properties decode N/A frame_data N/A 12 N/A N/A frame_end N/A Header channel_number body_size properties N/A N/A N/A frame_type N/A spec FRAME_BODY N/A N/A N/A frame_end N/A Body channel_number frame_data N/A N/A N/A frame_type N/A spec FRAME_HEARTBEAT N/A N/A N/A frame_end N/A Heartbeat N/A N/A N/A exceptions InvalidFrameError N/A Unknown frame type: %i frame_type N/A