Module ImportFrom alias alias alias alias Assign NameStore NameLoad ImportFrom alias Import alias ImportFrom alias alias Import alias Import alias Import alias Import alias ImportFrom alias If AttributeLoad NameLoad attr body ImportFrom alias orelse ImportFrom alias ImportFrom alias ImportFrom alias alias alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr Str Assign NameStore ListLoad Str Assign NameStore ListLoad AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr ClassDef bases body Expr Str FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Call NameLoad Lambda arguments args defaults AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Num Assign AttributeStore NameLoad attr Call NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str While UnaryOpNot AttributeLoad NameLoad attr body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad name NameStore body If AttributeLoad NameLoad attr body Assign TupleStore NameStore NameStore NameStore Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Break AugAssignAdd AttributeStore NameLoad attr Num If CompareNotIn AttributeLoad NameLoad attr TupleLoad SubscriptLoad AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr Num body Assign NameStore Call AttributeLoad Str attr AttributeLoad NameLoad attr SubscriptLoad AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad NameLoad keyword AttributeLoad NameLoad attr orelse If CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad orelse If CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad orelse If CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore AttributeLoad NameLoad attr Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad If CompareIn AttributeLoad NameLoad attr NameLoad body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad AttributeLoad AttributeLoad NameLoad attr attr orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Delete SubscriptDel AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr orelse Assign SubscriptStore AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad Delete SubscriptDel AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr If Call NameLoad NameLoad NameLoad body Raise NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr SubscriptLoad NameLoad Index AttributeLoad NameLoad attr Return NameLoad decorator_list Call NameLoad Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str If CompareIs NameLoad NameLoad body Return Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr If CompareNotEq NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad TryFinally body TryExcept body Return Call AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad NameLoad attr body Raise Call NameLoad ExceptHandler type AttributeLoad NameLoad attr name NameStore body If CompareEq Call NameLoad NameLoad AttributeLoad NameLoad attr body Raise Call NameLoad Raise finalbody If CompareNotEq NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list ClassDef bases body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr SubscriptLoad NameLoad Index AttributeLoad NameLoad attr Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Assign NameStore BinOpSub AttributeLoad NameLoad attr Num For NameStore Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad While UnaryOpNot Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr AugAssignAdd AttributeStore NameLoad attr Num decorator_list decorator_list
N/A __future__ absolute_import division print_function unicode_literals N/A __metaclass__ type threading Lock N/A sys collections defaultdict deque N/A six N/A logging N/A socket N/A errno utils get_errno N/A N/A six PY2 N/A Queue Queue N/A queue Queue concurrency synchronized exceptions UnexpectedFrame Timeout METHOD_NAME_MAP proto Method N/A spec spec FrameType N/A log N/A N/A logging getLogger amqpy N/A __all__ N/A MethodReader N/A _CONTENT_METHODS N/A N/A N/A spec Basic Return N/A N/A spec Basic Deliver N/A N/A spec Basic GetOk MethodReader N/A N/A N/A Read frames from the server and construct complete methods

    There should be one `MethodReader` instance per connection.

    In the case of a framing error, an :exc:`AMQPConnectionError` is placed in the queue.
    In the case of unexpected frames, an :exc:`ChannelError` is placed in the queue.
     __init__ N/A N/A self transport N/A N/A N/A 
        :param transport: transport to read from
        :type transport: amqpy.transport.Transport
         N/A N/A self transport transport N/A N/A self sock N/A transport sock N/A N/A self method_queue N/A deque N/A N/A self partial_methods N/A N/A N/A self expected_types N/A defaultdict N/A N/A N/A N/A N/A FrameType METHOD N/A N/A self frames_recv 0 N/A N/A self _method_read_lock N/A Lock N/A _next_method N/A N/A self N/A N/A N/A Read the next method from the source and process it

        Once one complete method has been assembled, it is placed in the internal queue. This
        method will block until a complete `Method` has been constructed, which may consist of one
        or more frames.
         N/A N/A N/A self method_queue N/A N/A N/A N/A frame N/A N/A N/A self transport read_frame N/A N/A N/A Exception N/A exc N/A N/A N/A six PY2 N/A N/A N/A _ _ tb N/A N/A sys exc_info N/A N/A exc tb tb N/A N/A N/A N/A self method_queue append exc N/A N/A N/A self frames_recv 1 N/A N/A N/A frame frame_type N/A N/A N/A self expected_types N/A N/A frame channel 8 N/A N/A msg N/A N/A Received frame type {} while expecting type: {} format N/A frame frame_type N/A N/A self expected_types N/A N/A frame channel N/A N/A N/A N/A self method_queue append N/A UnexpectedFrame msg channel_id N/A frame channel N/A N/A N/A N/A frame frame_type N/A FrameType METHOD N/A N/A N/A N/A self _process_method_frame frame N/A N/A N/A N/A frame frame_type N/A FrameType HEADER N/A N/A N/A N/A self _process_content_header frame N/A N/A N/A N/A frame frame_type N/A FrameType BODY N/A N/A N/A N/A self _process_content_body frame N/A _process_method_frame N/A N/A self frame N/A N/A N/A Process method frame

        :param frame: incoming frame
        :type frame: amqpy.proto.Frame
         N/A channel_id N/A frame channel N/A method N/A Method N/A N/A N/A method load_method_frame frame N/A N/A N/A method method_type _CONTENT_METHODS N/A N/A N/A N/A self partial_methods N/A channel_id method N/A N/A N/A self expected_types N/A channel_id N/A N/A spec FrameType HEADER N/A N/A N/A N/A N/A self method_queue append method N/A _process_content_header N/A N/A self frame N/A N/A N/A Process Content Header frames

        :param frame: incoming frame
        :type frame: amqpy.proto.Frame
         N/A method N/A N/A self partial_methods N/A N/A frame channel N/A N/A N/A method load_header_frame frame N/A N/A method complete N/A N/A N/A N/A N/A self method_queue append method N/A N/A N/A N/A self partial_methods pop N/A frame channel None N/A N/A N/A self expected_types N/A N/A frame channel N/A N/A N/A N/A self expected_types N/A N/A frame channel N/A N/A spec FrameType BODY N/A _process_content_body N/A N/A self frame N/A N/A N/A Process Content Body frames

        :param frame: incoming frame
        :type frame: amqpy.proto.Frame
         N/A method N/A N/A self partial_methods N/A N/A frame channel N/A N/A N/A method load_body_frame frame N/A N/A method complete N/A N/A N/A N/A N/A self method_queue append method N/A N/A N/A N/A self partial_methods pop N/A frame channel None N/A N/A N/A self expected_types N/A N/A frame channel N/A _read_method N/A N/A self N/A N/A N/A Read a method from the peer

        :return: method
        :rtype: amqpy.proto.Method
         N/A N/A N/A self _next_method N/A method N/A N/A N/A self method_queue popleft N/A N/A isinstance method Exception N/A N/A method N/A N/A N/A log debug N/A N/A {:7} channel: {} {} {} format Read: N/A method channel_id N/A method method_type N/A METHOD_NAME_MAP N/A N/A method method_type N/A method N/A N/A synchronized _method_read_lock read_method N/A N/A self timeout N/A None N/A N/A Read method

        :param timeout: timeout
        :type timeout: float
        :return: method
        :rtype: amqpy.proto.Method
        :raise amqpy.exceptions.Timeout: if the operation times out
         N/A N/A timeout None N/A N/A N/A N/A self _read_method N/A orig_timeout N/A N/A N/A self sock gettimeout N/A N/A orig_timeout timeout N/A N/A N/A N/A N/A self sock settimeout timeout N/A N/A N/A N/A N/A N/A N/A self _read_method N/A N/A N/A N/A socket timeout N/A N/A N/A Timeout N/A N/A N/A socket error N/A e N/A N/A N/A N/A get_errno e N/A errno EAGAIN N/A N/A N/A Timeout N/A N/A N/A N/A orig_timeout timeout N/A N/A N/A N/A N/A self sock settimeout orig_timeout N/A N/A MethodWriter N/A N/A N/A Write methods to the server by breaking them up and constructing multiple frames

    There should be one `MethodWriter` instance per connection, and all channels share that
    instance. This class is thread-safe. Any thread may call :meth:`write_method()` as long as no
    more than one thread is writing to any given `channel_id` at a time.
     __init__ N/A N/A self transport frame_max N/A N/A N/A 
        :param transport: transport to write to
        :param frame_max: maximum frame payload size in bytes
        :type transport: amqpy.transport.Transport
        :type frame_max: int
         N/A N/A self transport transport N/A N/A self frame_max frame_max N/A N/A self methods_sent 0 N/A write_method N/A N/A self method N/A N/A N/A Write method to connection, destined for the channel as set in `method.channel_id`

        This implementation uses a queue internally to prepare all frames before writing in order
        to detect issues.

        This method is thread safe only if the `channel_id` parameter is unique across concurrent
        invocations. The AMQP protocol allows interleaving frames destined for different channels,
        but not within the same channel. This means no more than one thread may safely operate on
        any given channel.

        :param method: method to write
        :type method: amqpy.proto.Method
         N/A transport N/A self transport N/A N/A N/A log debug N/A N/A {:7} channel: {} {} {} format Write: N/A method channel_id N/A method method_type N/A METHOD_NAME_MAP N/A N/A method method_type N/A frames N/A Queue N/A N/A N/A frames put N/A N/A method dump_method_frame N/A N/A method content N/A N/A N/A N/A frames put N/A N/A method dump_header_frame N/A chunk_size N/A N/A self frame_max 8 N/A frame N/A N/A method dump_body_frame chunk_size N/A N/A N/A N/A frames put frame N/A N/A N/A N/A frames empty N/A N/A N/A N/A transport write_frame N/A N/A frames get N/A N/A self methods_sent 1 N/A N/A