Module Expr Str Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Expr Str Assign NameStore ListLoad Str Str FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad kwarg body Expr Str Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Assign NameStore BoolOpOr NameLoad Dict If CompareNotIn Str NameLoad body Assign SubscriptStore NameLoad Index Str Call NameLoad Call AttributeLoad NameLoad attr If CompareNotIn Str NameLoad body Assign SubscriptStore NameLoad Index Str Call NameLoad Call AttributeLoad NameLoad attr If CompareNotIn Str NameLoad body Assign SubscriptStore NameLoad Index Str Call AttributeLoad NameLoad attr Return Call NameLoad NameLoad keyword NameLoad keyword NameLoad keyword NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Return AttributeLoad NameLoad attr If CompareIn Str AttributeLoad NameLoad attr body Return SubscriptLoad AttributeLoad NameLoad attr Index Str Assign NameStore Call NameLoad AttributeLoad NameLoad attr Assign SubscriptStore AttributeLoad NameLoad attr Index Str NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Str decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Raise Call NameLoad Str Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword SubscriptLoad AttributeLoad NameLoad attr Index Str decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Raise Call NameLoad Str Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword SubscriptLoad AttributeLoad NameLoad attr Index Str keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str If UnaryOpNot AttributeLoad NameLoad attr body Raise Call NameLoad Str Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword SubscriptLoad AttributeLoad NameLoad attr Index Str keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults Str NameLoad NameLoad body Expr Str Return Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str If BoolOpAnd AttributeLoad NameLoad attr CompareIn Str AttributeLoad NameLoad attr body Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index Str Index NameLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str If BoolOpOr UnaryOpNot AttributeLoad NameLoad attr UnaryOpNot NameLoad body Return NameLoad If CompareIn NameLoad AttributeLoad NameLoad attr body Return SubscriptLoad AttributeLoad NameLoad attr Index NameLoad If Call NameLoad NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad orelse Assign NameStore Call NameLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call NameLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body Assign NameStore Call NameLoad NameLoad If Call NameLoad NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad orelse If Call NameLoad NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad orelse If Call NameLoad NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad Call AttributeLoad NameLoad attr NameLoad orelse Assign SubscriptStore NameLoad Index NameLoad Call NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call NameLoad For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Expr Str Return Call NameLoad Call AttributeLoad NameLoad attr NameLoad decorator_list NameLoad decorator_list
N/A N/A AMQP-Storm Message. N/A json N/A uuid datetime datetime amqpstorm.base BaseMessage amqpstorm.compatibility try_utf8_decode amqpstorm.exception AMQPMessageError Message N/A BaseMessage N/A N/A AMQP Message N/A __slots__ N/A _auto_decode _decode_cache __init__ N/A N/A self channel auto_decode N/A True message N/A N/A 
        :param Channel channel: amqp-storm Channel
        :param bool auto_decode: Auto-decode strings when possible. Does not
                                 apply to to_dict, or to_tuple.
        :param str|unicode body: Message body
        :param dict method: Message method
        :param dict properties: Message properties
         N/A N/A N/A N/A super Message self __init__ channel message N/A N/A self _decode_cache N/A dict N/A N/A self _auto_decode auto_decode N/A create N/A N/A channel body properties N/A None N/A N/A Create a new Message.

        :param Channel channel: AMQP-Storm Channel
        :param bytes|str|unicode body: Message body
        :param dict properties: Message properties
        :rtype: Message
         N/A properties N/A properties N/A N/A N/A correlation_id properties N/A N/A N/A properties N/A correlation_id N/A str N/A N/A uuid uuid4 N/A N/A message_id properties N/A N/A N/A properties N/A message_id N/A str N/A N/A uuid uuid4 N/A N/A timestamp properties N/A N/A N/A properties N/A timestamp N/A N/A datetime utcnow N/A N/A Message channel auto_decode False body body properties properties N/A staticmethod body N/A N/A self N/A N/A N/A Return the Message Body.

            If auto_decode is enabled, the body will automatically be
            decoded using decode('utf-8') if possible.

        :rtype: bytes|str|unicode
         N/A N/A N/A self _auto_decode N/A N/A N/A self _body N/A N/A body N/A self _decode_cache N/A N/A N/A N/A self _decode_cache N/A body N/A body N/A try_utf8_decode N/A self _body N/A N/A N/A self _decode_cache N/A body body N/A body N/A property channel N/A N/A self N/A N/A N/A Return the Channel used by this message.

        :rtype: Channel
         N/A N/A self _channel N/A property method N/A N/A self N/A N/A N/A Return the Message Method.

            If auto_decode is enabled, the any strings will automatically be
            decoded using decode('utf-8') if possible.

        :rtype: dict
         N/A N/A N/A self _try_decode_utf8_content N/A self _method method N/A property properties N/A N/A self N/A N/A N/A Returns the Message Properties.

            If auto_decode is enabled, the any strings will automatically be
            decoded using decode('utf-8') if possible.

        :rtype: dict
         N/A N/A N/A self _try_decode_utf8_content N/A self _properties properties N/A property ack N/A N/A self N/A N/A N/A Acknowledge Message.

        :return:
         N/A N/A N/A self _method N/A N/A N/A AMQPMessageError Message.ack only available on incoming messages N/A N/A N/A N/A N/A self _channel basic ack delivery_tag N/A N/A self _method N/A delivery_tag N/A nack N/A N/A self requeue N/A True N/A N/A Negative Acknowledgement.

        :param bool requeue:
         N/A N/A N/A self _method N/A N/A N/A AMQPMessageError Message.nack only available on incoming messages N/A N/A N/A N/A N/A self _channel basic nack delivery_tag N/A N/A self _method N/A delivery_tag requeue requeue N/A reject N/A N/A self requeue N/A True N/A N/A Reject Message.

        :param bool requeue: Requeue the message
         N/A N/A N/A self _method N/A N/A N/A AMQPMessageError Message.reject only available on incoming messages N/A N/A N/A N/A N/A self _channel basic reject delivery_tag N/A N/A self _method N/A delivery_tag requeue requeue N/A publish N/A N/A self routing_key exchange mandatory immediate N/A False False N/A N/A Publish Message.

        :param str routing_key:
        :param str exchange:
        :param bool mandatory:
        :param bool immediate:
         N/A N/A N/A N/A N/A self _channel basic publish body N/A self _body routing_key routing_key exchange exchange properties N/A self _properties mandatory mandatory immediate immediate N/A app_id N/A N/A self N/A N/A N/A Get AMQP Message attribute: app_id.

        :return:
         N/A N/A N/A N/A self properties get app_id N/A property app_id N/A N/A self value N/A N/A N/A Set AMQP Message attribute: app_id.

        :return:
         N/A N/A N/A self _update_properties app_id value N/A N/A app_id setter message_id N/A N/A self N/A N/A N/A Get AMQP Message attribute: message_id.

        :return:
         N/A N/A N/A N/A self properties get message_id N/A property message_id N/A N/A self value N/A N/A N/A Set AMQP Message attribute: message_id.

        :return:
         N/A N/A N/A self _update_properties message_id value N/A N/A message_id setter content_encoding N/A N/A self N/A N/A N/A Get AMQP Message attribute: content_encoding.

        :return:
         N/A N/A N/A N/A self properties get content_encoding N/A property content_encoding N/A N/A self value N/A N/A N/A Set AMQP Message attribute: content_encoding.

        :return:
         N/A N/A N/A self _update_properties content_encoding value N/A N/A content_encoding setter content_type N/A N/A self N/A N/A N/A Get AMQP Message attribute: content_type.

        :return:
         N/A N/A N/A N/A self properties get content_type N/A property content_type N/A N/A self value N/A N/A N/A Set AMQP Message attribute: content_type.

        :return:
         N/A N/A N/A self _update_properties content_type value N/A N/A content_type setter correlation_id N/A N/A self N/A N/A N/A Get AMQP Message attribute: correlation_id.

        :return:
         N/A N/A N/A N/A self properties get correlation_id N/A property correlation_id N/A N/A self value N/A N/A N/A Set AMQP Message attribute: correlation_id.

        :return:
         N/A N/A N/A self _update_properties correlation_id value N/A N/A correlation_id setter delivery_mode N/A N/A self N/A N/A N/A Get AMQP Message attribute: delivery_mode.

        :return:
         N/A N/A N/A N/A self properties get delivery_mode N/A property delivery_mode N/A N/A self value N/A N/A N/A Set AMQP Message attribute: delivery_mode.

        :return:
         N/A N/A N/A self _update_properties delivery_mode value N/A N/A delivery_mode setter timestamp N/A N/A self N/A N/A N/A Get AMQP Message attribute: timestamp.

        :return:
         N/A N/A N/A N/A self properties get timestamp N/A property timestamp N/A N/A self value N/A N/A N/A Set AMQP Message attribute: timestamp.

        :return:
         N/A N/A N/A self _update_properties timestamp value N/A N/A timestamp setter priority N/A N/A self N/A N/A N/A Get AMQP Message attribute: priority.

        :return:
         N/A N/A N/A N/A self properties get priority N/A property priority N/A N/A self value N/A N/A N/A Set AMQP Message attribute: priority.

        :return:
         N/A N/A N/A self _update_properties priority value N/A N/A priority setter reply_to N/A N/A self N/A N/A N/A Get AMQP Message attribute: reply_to.

        :return:
         N/A N/A N/A N/A self properties get reply_to N/A property reply_to N/A N/A self value N/A N/A N/A Set AMQP Message attribute: reply_to.

        :return:
         N/A N/A N/A self _update_properties reply_to value N/A N/A reply_to setter json N/A N/A self N/A N/A N/A Deserialize the message body, if it is JSON.

        :return:
         N/A N/A N/A json loads N/A self body N/A _update_properties N/A N/A self name value N/A N/A N/A Update properties, and keep cache up-to-date if auto decode is
        enabled.

        :param str name: Key
        :param obj value: Value
        :return:
         N/A N/A N/A self _auto_decode N/A properties N/A self _decode_cache N/A N/A N/A N/A N/A self _decode_cache N/A properties N/A name value N/A N/A N/A self _properties N/A name value N/A _try_decode_utf8_content N/A N/A self content content_type N/A N/A N/A Generic function to decode content.

        :param object content:
        :return:
         N/A N/A N/A N/A self _auto_decode N/A content N/A N/A content N/A N/A content_type N/A self _decode_cache N/A N/A N/A N/A self _decode_cache N/A content_type N/A N/A isinstance content dict N/A N/A content N/A N/A self _try_decode_dict content N/A N/A content N/A try_utf8_decode content N/A N/A N/A self _decode_cache N/A content_type content N/A content N/A _try_decode_dict N/A N/A self content N/A N/A N/A Decode content of a dictionary.

        :param dict content:
        :return:
         N/A result N/A dict N/A N/A key value N/A N/A content items N/A N/A key N/A try_utf8_decode key N/A N/A isinstance value dict N/A N/A N/A result N/A key N/A N/A self _try_decode_dict value N/A N/A N/A isinstance value list N/A N/A N/A result N/A key N/A N/A self _try_decode_list value N/A N/A N/A isinstance value tuple N/A N/A N/A result N/A key N/A N/A self _try_decode_tuple value N/A N/A N/A result N/A key N/A try_utf8_decode value N/A result N/A _try_decode_list N/A N/A content N/A N/A N/A Decode content of a list.

        :param list|tuple content:
        :return:
         N/A result N/A list N/A value content N/A N/A N/A N/A result append N/A try_utf8_decode value N/A result N/A staticmethod _try_decode_tuple N/A N/A content N/A N/A N/A Decode content of a tuple.

        :param tuple content:
        :return:
         N/A N/A tuple N/A N/A Message _try_decode_list content N/A staticmethod N/A