Module Expr Str Import alias Import alias ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults Num Num NameLoad body Expr Str If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad keyword NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults Str NameLoad NameLoad body Expr Str If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str orelse If AttributeLoad AttributeLoad NameLoad attr attr body Raise Call NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad With BoolOpAnd AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr body Assign NameStore Call AttributeLoad NameLoad attr NameLoad If BoolOpAnd NameLoad NameLoad body Return Call AttributeLoad NameLoad attr Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad Str Str NameLoad NameLoad NameLoad NameLoad body Expr Str If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str orelse If BoolOpAnd CompareIsNot NameLoad NameLoad UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str Assign AttributeStore AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore SubscriptLoad NameLoad Index Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults Str body Expr Str If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults Str NameLoad NameLoad NameLoad body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad Assign NameStore BoolOpOr NameLoad Dict Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr keyword Call NameLoad NameLoad keyword NameLoad Assign NameStore ListLoad NameLoad NameLoad For NameStore Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad If AttributeLoad AttributeLoad NameLoad attr attr body With AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr body Return Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Str If BoolOpAnd CompareIsNot NameLoad NameLoad UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad body Expr Str If BoolOpAnd CompareIsNot NameLoad NameLoad UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Str If BoolOpAnd CompareIsNot NameLoad NameLoad UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body Expr Str If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call AttributeLoad NameLoad attr NameLoad body Raise Call NameLoad Str orelse If BoolOpAnd NameLoad UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str If Call AttributeLoad NameLoad attr NameLoad body If CompareNotIn Str NameLoad body Assign SubscriptStore NameLoad Index Str Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad orelse If BoolOpAnd AttributeLoad NameLoad attr Call NameLoad NameLoad NameLoad body Assign NameStore Call NameLoad NameLoad keyword Str Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr ListLoad Str Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr ListLoad Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad keyword NameLoad If UnaryOpNot Call NameLoad NameLoad AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad Return NameLoad Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad keyword NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Return Call NameLoad keyword AttributeLoad NameLoad attr keyword NameLoad keyword Call NameLoad NameLoad keyword Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr ListLoad Str Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr If Call NameLoad NameLoad AttributeLoad AttributeLoad NameLoad attr attr body Return NameLoad orelse If Call NameLoad NameLoad AttributeLoad AttributeLoad NameLoad attr attr body Return NameLoad orelse Raise Call NameLoad BinOpMod Str TupleLoad NameLoad Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr BinOpDiv Call NameLoad NameLoad Call NameLoad NameLoad For NameStore Call AttributeLoad NameLoad attr Num NameLoad body Assign NameStore BinOpMult NameLoad NameLoad Assign NameStore BinOpAdd NameLoad NameLoad If CompareGt NameLoad Call NameLoad NameLoad body Assign NameStore Call NameLoad NameLoad Expr Yield Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Slice NameLoad NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call NameLoad While CompareLt Call NameLoad NameLoad NameLoad body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad keyword NameLoad keyword NameLoad If UnaryOpNot NameLoad body Break AugAssignAdd NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad Return NameLoad decorator_list decorator_list
N/A N/A AMQP-Storm Channel.Basic. N/A logging N/A math pamqp body pamqp_body pamqp header pamqp_header pamqp specification pamqp_spec amqpstorm compatibility amqpstorm.base FRAME_MAX amqpstorm.base Handler amqpstorm.exception AMQPChannelError amqpstorm.exception AMQPInvalidArgument amqpstorm.exception AMQPMessageError amqpstorm.message Message N/A LOGGER N/A N/A logging getLogger __name__ Basic N/A Handler N/A N/A AMQP Channel.basic qos N/A N/A self prefetch_count prefetch_size global_ N/A 0 0 False N/A N/A Specify quality of service.

        :param int prefetch_count: Prefetch window in messages
        :param int/long prefetch_size: Prefetch window in octets
        :param bool global_: Apply to entire connection

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :rtype: dict
         N/A N/A N/A N/A compatibility is_integer prefetch_count N/A N/A N/A AMQPInvalidArgument prefetch_count should be an integer N/A N/A N/A N/A N/A compatibility is_integer prefetch_size N/A N/A N/A AMQPInvalidArgument prefetch_size should be an integer N/A N/A N/A N/A isinstance global_ bool N/A N/A N/A AMQPInvalidArgument global_ should be a boolean N/A qos_frame N/A N/A N/A pamqp_spec Basic Qos prefetch_count prefetch_count prefetch_size prefetch_size global_ global_ N/A N/A N/A N/A self _channel rpc_request qos_frame N/A get N/A N/A self queue no_ack to_dict N/A False True N/A N/A Fetch a single message.

        :param str queue: Queue name
        :param bool no_ack: No acknowledgement needed
        :param bool to_dict: Should incoming messages be converted to a
                    dictionary before delivery.

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :returns: Returns a single message, as long as there is a message in
                  the queue. If no message is available, returns None.
        :rtype: dict|Message|None
         N/A N/A N/A N/A compatibility is_string queue N/A N/A N/A AMQPInvalidArgument queue should be a string N/A N/A N/A N/A isinstance no_ack bool N/A N/A N/A AMQPInvalidArgument no_ack should be a boolean N/A N/A N/A N/A self _channel consumer_tags N/A N/A N/A AMQPChannelError Cannot call 'get' when channel is set to consume N/A get_frame N/A N/A N/A pamqp_spec Basic Get queue queue no_ack no_ack N/A N/A N/A N/A self _channel lock N/A N/A N/A self _channel rpc lock N/A N/A message N/A N/A self _get_message get_frame N/A N/A message to_dict N/A N/A N/A N/A message to_dict N/A message N/A recover N/A N/A self requeue N/A False N/A N/A Redeliver unacknowledged messages.

        :param bool requeue: Requeue the messages

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :rtype: dict
         N/A N/A N/A isinstance requeue bool N/A N/A N/A AMQPInvalidArgument requeue should be a boolean N/A recover_frame N/A N/A N/A pamqp_spec Basic Recover requeue requeue N/A N/A N/A N/A self _channel rpc_request recover_frame N/A consume N/A N/A self callback queue consumer_tag exclusive no_ack no_local arguments N/A None False False False None N/A N/A Start a queue consumer.

        :param function callback: Message callback
        :param str queue: Queue name
        :param str consumer_tag: Consumer tag
        :param bool no_local: Do not deliver own messages
        :param bool no_ack: No acknowledgement needed
        :param bool exclusive: Request exclusive access
        :param dict arguments: Arguments for declaration

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :returns: Consumer tag
        :rtype: str
         N/A N/A N/A N/A compatibility is_string queue N/A N/A N/A AMQPInvalidArgument queue should be a string N/A N/A N/A N/A N/A compatibility is_string consumer_tag N/A N/A N/A AMQPInvalidArgument consumer_tag should be a string N/A N/A N/A N/A isinstance exclusive bool N/A N/A N/A AMQPInvalidArgument exclusive should be a boolean N/A N/A N/A N/A isinstance no_ack bool N/A N/A N/A AMQPInvalidArgument no_ack should be a boolean N/A N/A N/A N/A isinstance no_local bool N/A N/A N/A AMQPInvalidArgument no_local should be a boolean N/A N/A N/A N/A arguments None N/A N/A isinstance arguments dict N/A N/A N/A AMQPInvalidArgument arguments should be a dict or None N/A N/A N/A self _channel consumer_callback callback N/A consume_frame N/A N/A N/A pamqp_spec Basic Consume queue queue consumer_tag consumer_tag exclusive exclusive no_local no_local no_ack no_ack arguments arguments N/A result N/A N/A N/A self _channel rpc_request consume_frame N/A consumer_tag N/A result N/A consumer_tag N/A N/A N/A N/A self _channel add_consumer_tag consumer_tag N/A consumer_tag N/A cancel N/A N/A self consumer_tag N/A N/A N/A Cancel a queue consumer.

        :param str consumer_tag: Consumer tag

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :rtype: dict
         N/A N/A N/A N/A compatibility is_string consumer_tag N/A N/A N/A AMQPInvalidArgument consumer_tag should be a string N/A cancel_frame N/A N/A N/A pamqp_spec Basic Cancel consumer_tag consumer_tag N/A result N/A N/A N/A self _channel rpc_request cancel_frame N/A N/A N/A N/A self _channel remove_consumer_tag consumer_tag N/A result N/A publish N/A N/A self body routing_key exchange properties mandatory immediate N/A None False False N/A N/A Publish a Message.

        :param str|unicode body: Message payload
        :param str routing_key: Message routing key
        :param str exchange: The exchange to publish the message to
        :param dict properties: Message properties
        :param bool mandatory: Requires the message is published
        :param bool immediate: Request immediate delivery

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :rtype: bool|None
         N/A N/A N/A self _validate_publish_parameters body exchange immediate mandatory properties routing_key N/A properties N/A properties N/A N/A body N/A N/A self _handle_utf8_payload body properties N/A properties N/A N/A N/A pamqp_spec Basic Properties properties N/A method_frame N/A N/A N/A pamqp_spec Basic Publish exchange exchange routing_key routing_key mandatory mandatory immediate immediate N/A header_frame N/A N/A pamqp_header ContentHeader body_size N/A len body properties properties N/A send_buffer N/A method_frame header_frame N/A body_frame N/A N/A self _create_content_body body N/A N/A N/A N/A send_buffer append body_frame N/A N/A N/A self _channel confirming_deliveries N/A N/A N/A N/A N/A self _channel rpc lock N/A N/A N/A N/A self _publish_confirm send_buffer N/A N/A N/A N/A self _channel write_frames send_buffer N/A ack N/A N/A self delivery_tag multiple N/A None False N/A N/A Acknowledge Message.

        :param int/long delivery_tag: Server-assigned delivery tag
        :param bool multiple: Acknowledge multiple messages

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :return:
         N/A N/A N/A delivery_tag None N/A N/A N/A compatibility is_integer delivery_tag N/A N/A N/A AMQPInvalidArgument delivery_tag should be an integer or None N/A N/A N/A N/A isinstance multiple bool N/A N/A N/A AMQPInvalidArgument multiple should be a boolean N/A ack_frame N/A N/A N/A pamqp_spec Basic Ack delivery_tag delivery_tag multiple multiple N/A N/A N/A N/A self _channel write_frame ack_frame N/A nack N/A N/A self delivery_tag multiple requeue N/A None False True N/A N/A Negative Acknowledgement.

        :param int/long delivery_tag: Server-assigned delivery tag
        :param bool multiple: Negative acknowledge multiple messages
        :param bool requeue: Requeue message

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :return:
         N/A N/A N/A delivery_tag None N/A N/A N/A compatibility is_integer delivery_tag N/A N/A N/A AMQPInvalidArgument delivery_tag should be an integer or None N/A N/A N/A N/A isinstance multiple bool N/A N/A N/A AMQPInvalidArgument multiple should be a boolean N/A N/A N/A N/A isinstance requeue bool N/A N/A N/A AMQPInvalidArgument requeue should be a boolean N/A nack_frame N/A N/A N/A pamqp_spec Basic Nack delivery_tag delivery_tag multiple multiple requeue requeue N/A N/A N/A N/A self _channel write_frame nack_frame N/A reject N/A N/A self delivery_tag requeue N/A None True N/A N/A Reject Message.

        :param int/long delivery_tag: Server-assigned delivery tag
        :param bool requeue: Requeue the message

        :raises AMQPInvalidArgument: Invalid Parameters
        :raises AMQPChannelError: Raises if the channel encountered an error.
        :raises AMQPConnectionError: Raises if the connection
                                     encountered an error.

        :return:
         N/A N/A N/A delivery_tag None N/A N/A N/A compatibility is_integer delivery_tag N/A N/A N/A AMQPInvalidArgument delivery_tag should be an integer or None N/A N/A N/A N/A isinstance requeue bool N/A N/A N/A AMQPInvalidArgument requeue should be a boolean N/A reject_frame N/A N/A N/A pamqp_spec Basic Reject delivery_tag delivery_tag requeue requeue N/A N/A N/A N/A self _channel write_frame reject_frame N/A _validate_publish_parameters N/A N/A body exchange immediate mandatory properties routing_key N/A N/A N/A Validate Publish Parameters.

        :param str|unicode body:
        :param str routing_key:
        :param str exchange:
        :param dict properties:
        :param bool mandatory:
        :param bool immediate:
        :raises  AMQPInvalidArgument: Invalid Parameters
        :return:
         N/A N/A N/A N/A compatibility is_string body N/A N/A N/A AMQPInvalidArgument body should be a string N/A N/A N/A N/A N/A compatibility is_string routing_key N/A N/A N/A AMQPInvalidArgument routing_key should be a string N/A N/A N/A N/A N/A compatibility is_string exchange N/A N/A N/A AMQPInvalidArgument exchange should be a string N/A N/A N/A properties N/A N/A isinstance properties dict N/A N/A N/A AMQPInvalidArgument properties should be a dict or None N/A N/A N/A N/A isinstance mandatory bool N/A N/A N/A AMQPInvalidArgument mandatory should be a boolean N/A N/A N/A N/A isinstance immediate bool N/A N/A N/A AMQPInvalidArgument immediate should be a boolean N/A staticmethod _handle_utf8_payload N/A N/A body properties N/A N/A N/A Update the Body and Properties to the appropriate encoding.

        :param str|unicode body:
        :param dict properties:
        :return:
         N/A N/A N/A compatibility is_unicode body N/A N/A N/A content_encoding properties N/A N/A N/A properties N/A content_encoding utf-8 N/A encoding N/A properties N/A content_encoding N/A body N/A N/A body encode encoding N/A N/A N/A N/A compatibility PYTHON3 N/A isinstance body str N/A N/A body N/A bytes body encoding utf-8 N/A body N/A staticmethod _get_message N/A N/A self get_frame N/A N/A N/A Get and return a message using a Basic.Get frame.

        :param Basic.Get get_frame:
        :rtype: Message
         N/A uuid_get N/A N/A N/A N/A self _channel rpc register_request N/A get_frame valid_responses N/A uuid_header N/A N/A N/A N/A self _channel rpc register_request N/A ContentHeader N/A uuid_body N/A N/A N/A N/A self _channel rpc register_request N/A ContentBody N/A N/A N/A N/A self _channel write_frame get_frame N/A get_frame N/A N/A N/A N/A self _channel rpc get_request uuid_get raw True N/A N/A N/A isinstance get_frame N/A N/A pamqp_spec Basic GetOk N/A N/A N/A N/A N/A N/A self _channel rpc remove uuid_header N/A N/A N/A N/A N/A self _channel rpc remove uuid_body N/A None N/A content_header N/A N/A N/A N/A self _channel rpc get_request uuid_header raw True N/A body N/A N/A self _get_content_body uuid_body N/A content_header body_size N/A N/A Message channel N/A self _channel body body method N/A dict get_frame properties N/A dict N/A content_header properties N/A _publish_confirm N/A N/A self send_buffer N/A N/A N/A Confirm that message was published successfully.

        :param list send_buffer:
        :rtype: bool
         N/A confirm_uuid N/A N/A N/A N/A self _channel rpc register_request N/A Basic.Ack Basic.Nack N/A N/A N/A N/A self _channel write_frames send_buffer N/A result N/A N/A N/A N/A self _channel rpc get_request confirm_uuid raw True N/A N/A N/A N/A self _channel check_for_errors N/A N/A isinstance result N/A N/A pamqp_spec Basic Ack N/A N/A True N/A N/A N/A isinstance result N/A N/A pamqp_spec Basic Nack N/A N/A False N/A N/A N/A AMQPMessageError N/A Unexpected Error: %s - %s N/A result N/A dict result N/A _create_content_body N/A N/A body N/A N/A N/A Split body based on the maximum frame size.

            This function is based on code from Rabbitpy.
            https://github.com/gmr/rabbitpy

        :param str body:
        :rtype: collections.Iterable
         N/A frames N/A int N/A N/A math ceil N/A N/A len body N/A float FRAME_MAX N/A offset N/A N/A compatibility RANGE 0 frames N/A N/A start_frame N/A FRAME_MAX offset N/A end_frame N/A start_frame FRAME_MAX N/A N/A end_frame N/A len body N/A N/A end_frame N/A len body N/A N/A N/A N/A pamqp_body ContentBody N/A body N/A start_frame end_frame N/A staticmethod _get_content_body N/A N/A self uuid_body body_size N/A N/A N/A Get Content Body using RPC requests.

        :param str uuid_body: Rpc Identifier.
        :param int body_size: Content Size.
        :rtype: str
         N/A body N/A bytes N/A N/A N/A len body body_size N/A N/A body_piece N/A N/A N/A N/A self _channel rpc get_request uuid_body raw True multiple True N/A N/A body_piece N/A N/A N/A body N/A body_piece value N/A N/A N/A N/A N/A self _channel rpc remove uuid_body N/A body N/A N/A