Module Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias identifier ImportFrom alias alias Assign NameStore Num ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults kwarg body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str SubscriptLoad AttributeLoad NameLoad attr Index Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad NameLoad attr attr Str Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If AttributeLoad NameLoad attr body Raise Call AttributeLoad NameLoad attr BinOpMod Str AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Str decorator_list FunctionDef arguments args NameParam defaults body Raise Call NameLoad Str decorator_list FunctionDef arguments args NameParam defaults body Raise Call NameLoad Str decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad Assign NameStore NameLoad Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam defaults kwarg body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Dict decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore AttributeLoad NameLoad attr If UnaryOpNot AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body TryExcept body Expr Call AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad NameLoad attr body Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults kwarg body For NameStore Call NameLoad Num body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad body Return NameLoad orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults kwarg body Assign NameStore BoolOpOr BoolOpAnd NameLoad Str Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Assign NameStore Call AttributeLoad NameLoad attr While NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr If NameLoad body Break If CompareGt BinOpSub Call AttributeLoad NameLoad attr NameLoad NameLoad body Raise Call AttributeLoad NameLoad attr Str Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str If BoolOpOr UnaryOpNot NameLoad CompareNotIn NameLoad AttributeLoad NameLoad attr body Return Expr Call SubscriptLoad AttributeLoad NameLoad attr Index NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str For NameStore Call NameLoad body If BoolOpAnd NameLoad CompareGtE NameLoad NameLoad body Raise NameLoad Expr Call AttributeLoad NameLoad attr Expr Yield NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults vararg kwarg body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword Str decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body TryExcept body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad body Return NameLoad orelse Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Return Call AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults Num NameLoad NameLoad body Assign NameStore Str If CompareEq NameLoad Num body Assign NameStore Str Assign NameStore BoolOpOr NameLoad Num Return Dict Str Str Str Str Str NameLoad NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults kwarg body Assign SubscriptStore NameLoad Index Str NameLoad Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If BoolOpOr UnaryOpNot AttributeLoad NameLoad attr CompareNotIn NameLoad AttributeLoad NameLoad attr body Return Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body For NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad NameLoad attr NameLoad If AttributeLoad NameLoad attr body TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type AttributeLoad NameLoad attr body Pass decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Return AttributeLoad NameLoad attr decorator_list NameLoad decorator_list
N/A N/A time N/A socket itertools count stompy Client stompy Empty QueueEmpty carrot.backends.base BaseMessage BaseBackend N/A DEFAULT_PORT 61613 Message N/A BaseMessage N/A N/A A message received by the STOMP broker.

    Usually you don't insantiate message objects yourself, but receive
    them using a :class:`carrot.messaging.Consumer`.

    :param backend: see :attr:`backend`.
    :param frame: see :attr:`_frame`.

    .. attribute:: body

        The message body.

    .. attribute:: delivery_tag

        The message delivery tag, uniquely identifying this message.

    .. attribute:: backend

        The message backend used.
        A subclass of :class:`carrot.backends.base.BaseBackend`.

    .. attribute:: _frame

        The frame received by the STOMP client. This is considered a private
        variable and should never be used in production code.

     __init__ N/A N/A self backend frame N/A kwargs N/A N/A N/A self _frame frame N/A N/A self backend backend N/A N/A kwargs N/A body N/A frame body N/A N/A kwargs N/A delivery_tag N/A N/A frame headers N/A message-id N/A N/A kwargs N/A content_type N/A N/A N/A frame headers get content-type N/A N/A kwargs N/A content_encoding N/A N/A N/A frame headers get content-encoding N/A N/A kwargs N/A priority N/A N/A N/A frame headers get priority N/A N/A N/A N/A super Message self __init__ backend kwargs N/A ack N/A N/A self N/A N/A N/A Acknowledge this message as being processed.,
        This will remove the message from the queue.

        :raises MessageStateError: If the message has already been
            acknowledged/requeued/rejected.

         N/A N/A self acknowledged N/A N/A N/A N/A self MessageStateError N/A Message already acknowledged with state: %s N/A self _state N/A N/A N/A N/A self backend ack N/A self _frame N/A N/A self _state ACK N/A reject N/A N/A self N/A N/A N/A N/A NotImplementedError The STOMP backend does not implement basic.reject N/A requeue N/A N/A self N/A N/A N/A N/A NotImplementedError The STOMP backend does not implement requeue N/A N/A Backend N/A BaseBackend N/A N/A Stomp Client N/A Message Message N/A default_port DEFAULT_PORT __init__ N/A N/A self connection N/A kwargs N/A N/A N/A self connection connection N/A N/A self default_port N/A N/A kwargs get default_port N/A self default_port N/A N/A self _channel None N/A N/A self _consumers N/A N/A N/A self _callbacks N/A N/A establish_connection N/A N/A self N/A N/A N/A conninfo N/A self connection N/A N/A N/A conninfo port N/A N/A N/A conninfo port N/A self default_port N/A stomp N/A N/A self Stomp N/A conninfo hostname N/A conninfo port N/A N/A N/A stomp connect username N/A conninfo userid password N/A conninfo password N/A N/A stomp drain_events N/A self drain_events N/A stomp N/A close_connection N/A N/A self connection N/A N/A N/A N/A N/A N/A N/A connection disconnect N/A N/A N/A N/A socket error N/A N/A N/A queue_exists N/A N/A self queue N/A N/A N/A True N/A queue_purge N/A N/A self queue N/A kwargs N/A N/A purge_count N/A count 0 N/A N/A N/A N/A frame N/A N/A N/A self channel get_nowait N/A N/A N/A QueueEmpty N/A N/A purge_count N/A N/A N/A N/A N/A self channel ack frame N/A declare_consumer N/A N/A self queue no_ack callback consumer_tag N/A kwargs N/A N/A ack N/A N/A no_ack auto client N/A N/A N/A N/A self channel subscribe queue ack ack N/A N/A N/A self _consumers N/A consumer_tag queue N/A N/A N/A self _callbacks N/A queue callback N/A drain_events N/A N/A self timeout N/A None N/A N/A start_time N/A N/A time time N/A True N/A N/A frame N/A N/A N/A self channel get N/A frame N/A N/A N/A N/A N/A N/A N/A time time time_start timeout N/A N/A N/A N/A socket timeout the operation timed out. N/A queue N/A N/A N/A frame headers get destination N/A N/A N/A queue N/A queue N/A self _callbacks N/A N/A N/A N/A N/A N/A self _callbacks N/A queue frame N/A consume N/A N/A self limit N/A None N/A N/A Returns an iterator that waits for one message at a time. N/A total_message_count N/A count N/A N/A N/A limit N/A total_message_count limit N/A N/A StopIteration N/A N/A N/A self drain_events N/A N/A True N/A queue_declare N/A N/A self queue N/A args kwargs N/A N/A N/A N/A N/A self channel subscribe queue ack client N/A get N/A N/A self queue no_ack N/A False N/A N/A N/A N/A frame N/A N/A N/A self channel get_nowait N/A N/A N/A QueueEmpty N/A N/A None N/A N/A N/A N/A self message_to_python frame N/A ack N/A N/A self frame N/A N/A N/A N/A N/A N/A self channel ack frame N/A message_to_python N/A N/A self raw_message N/A N/A N/A Convert encoded message body back to a Python value. N/A N/A N/A self Message backend self frame raw_message N/A prepare_message N/A N/A self message_data delivery_mode priority content_type content_encoding N/A 0 None None N/A N/A persistent false N/A N/A delivery_mode 2 N/A N/A persistent true N/A priority N/A priority 0 N/A N/A body persistent priority content-encoding content-type message_data persistent priority content_encoding content_type N/A publish N/A N/A self message exchange routing_key N/A kwargs N/A N/A N/A message N/A destination exchange N/A N/A N/A N/A N/A self channel stomp send message N/A cancel N/A N/A self consumer_tag N/A N/A N/A N/A N/A N/A self _channel N/A consumer_tag N/A self _consumers N/A N/A N/A queue N/A N/A N/A self _consumers pop consumer_tag N/A N/A N/A N/A self channel unsubscribe queue N/A close N/A N/A self N/A N/A N/A consumer_tag N/A N/A N/A self _consumers keys N/A N/A N/A N/A self cancel consumer_tag N/A N/A self _channel N/A N/A N/A N/A N/A N/A N/A self _channel disconnect N/A N/A N/A N/A socket error N/A N/A N/A channel N/A N/A self N/A N/A N/A N/A N/A self _channel N/A N/A N/A self _channel N/A N/A self establish_connection N/A N/A self _channel N/A property N/A