Module Expr Str Import alias Import alias Import alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad Expr Yield NameLoad decorator_list AttributeLoad NameLoad attr ClassDef bases NameLoad body Assign NameStore Str Assign NameStore Str Assign NameStore Dict Str Str NameLoad NameLoad FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Assign AttributeStore AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr Assign AttributeStore AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Assign AttributeStore AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Print Str decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call NameLoad AttributeLoad NameLoad attr TryExcept body Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler body Expr Call AttributeLoad NameLoad attr Raise Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Assign NameStore BinOpMod Str Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword NameLoad keyword Str Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword BinOpMod Str AttributeLoad NameLoad attr keyword Str keyword NameLoad Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword BinOpMod Str AttributeLoad NameLoad attr keyword Str keyword NameLoad Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword BinOpMod Str AttributeLoad NameLoad attr keyword Str keyword NameLoad Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr decorator_list ClassDef bases NameLoad body Assign NameStore Num FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad keyword NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr BinOpAdd AttributeLoad NameLoad attr Num If NameLoad body Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam defaults body Expr Str If CompareEq Call AttributeLoad NameLoad attr NameLoad NameLoad body Print BinOpMod Str NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Assign AttributeStore NameLoad attr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Assign NameStore Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad attr AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Assign NameStore Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad attr AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Assign AttributeStore NameLoad attr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Assign AttributeStore NameLoad attr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Call NameLoad AttributeLoad NameLoad attr Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str Assign NameStore BinOpMod Str Call NameLoad Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword NameLoad Assign NameStore Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad For NameStore Call NameLoad Num body Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Str keyword Call NameLoad Call NameLoad NameLoad Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad keyword NameLoad attr AttributeLoad NameLoad attr Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num decorator_list AttributeLoad NameLoad attr decorator_list ClassDef bases NameLoad body Assign NameStore Num Assign NameStore ListLoad FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad Num body Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad NameLoad NameLoad attr AttributeLoad NameLoad attr If BoolOpAnd NameLoad CompareNotIn AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr BinOpAdd AttributeLoad NameLoad attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword AttributeLoad NameLoad attr keyword NameLoad orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr BinOpAdd AttributeLoad NameLoad attr Num Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam NameParam NameParam defaults Num body Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr BinOpAdd AttributeLoad NameLoad attr Num Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword AttributeLoad NameLoad attr keyword NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Assign NameStore Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad keyword NameLoad attr AttributeLoad NameLoad attr For NameStore Call NameLoad Num body Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Str keyword Call NameLoad Call NameLoad NameLoad Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Expr Str Expr Yield Call AttributeLoad NameLoad attr Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword Str keyword Str Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Assign NameStore Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad attr AttributeLoad NameLoad attr For NameStore Call NameLoad Num body Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr keyword Str keyword Str keyword Call NameLoad Call NameLoad NameLoad Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr keyword Str keyword NameLoad keyword Str Assign NameStore Yield Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad Call AttributeLoad Call AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad attr AttributeLoad NameLoad attr Expr Yield Call NameLoad Num Expr Yield Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num Expr Yield Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list AttributeLoad NameLoad attr decorator_list
N/A N/A 
Test cases for AmqpFactory
These are test cases for only Jasmin's code, smpp.twisted tests are not included here
 N/A time N/A logging N/A uuid twisted.trial.unittest TestCase twisted.internet defer reactor jasmin.queues.configs AmqpConfig jasmin.queues.factory AmqpFactory txamqp.queue Closed txamqp.content Content waitFor N/A N/A seconds N/A N/A N/A waitDeferred N/A N/A defer Deferred N/A N/A N/A reactor callLater seconds N/A waitDeferred callback None N/A N/A waitDeferred N/A N/A defer inlineCallbacks AmqpTestCase N/A TestCase N/A N/A exchange_name CONNECTOR-00 N/A message Any Message N/A configArgs N/A reconnectOnConnectionFailure reconnectOnConnectionLoss False False setUp N/A N/A self N/A N/A N/A N/A self config N/A AmqpConfig N/A N/A N/A self config host N/A N/A N/A self configArgs get amqp_host localhost N/A N/A N/A self config port N/A N/A N/A self configArgs get amqp_port 5672 N/A N/A N/A self config username N/A N/A N/A self configArgs get amqp_username guest N/A N/A N/A self config password N/A N/A N/A self configArgs get amqp_password guest N/A N/A N/A self config log_level N/A N/A N/A self configArgs get amqp_log_level N/A logging DEBUG N/A N/A N/A self config reconnectOnConnectionFailure N/A N/A N/A self configArgs get reconnectOnConnectionFailure True N/A N/A N/A self config reconnectOnConnectionLoss N/A N/A N/A self configArgs get reconnectOnConnectionLoss True N/A N/A self amqp None N/A requirement_disclaimer N/A N/A self N/A N/A N/A failed to connect to an AMQP broker; These tests are designed to run against a running instance of a AMQP broker N/A connect N/A N/A self N/A N/A N/A N/A self amqp N/A AmqpFactory N/A self config N/A N/A N/A N/A N/A N/A N/A self amqp connect N/A N/A N/A N/A N/A N/A self requirement_disclaimer N/A N/A N/A N/A N/A N/A self amqp getChannelReadyDeferred N/A N/A defer inlineCallbacks N/A ConnectTestCase N/A AmqpTestCase N/A test_connect N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks test_connect_and_exchange_declare N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A exchange_name N/A %s_randomName N/A N/A time time N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange exchange_name type fanout N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks N/A PublishTestCase N/A AmqpTestCase N/A test_publish_to_topic_exchange N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange N/A %s_topic N/A self exchange_name type topic durable True N/A N/A N/A N/A N/A self amqp publish exchange N/A self exchange_name routing_key submit.sm content N/A Content N/A self message N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks test_publish_to_direct_exchange N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange N/A %s_direct N/A self exchange_name type direct durable True N/A N/A N/A N/A N/A self amqp publish exchange N/A self exchange_name routing_key submit_sm content N/A Content N/A self message N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks test_publish_to_fanout_exchange N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange N/A %s_fanout N/A self exchange_name type fanout durable True N/A N/A N/A N/A N/A self amqp publish exchange N/A self exchange_name routing_key submit_sm content N/A Content N/A self message N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks test_publish_to_queue N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm.connector01 N/A N/A N/A N/A N/A self amqp publish routing_key submit.sm.connector01 content N/A Content N/A self message N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks N/A ConsumeTools N/A AmqpTestCase N/A N/A consumedMessages 0 _callback N/A N/A self message queue ack N/A False N/A N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback queue ack ack addErrback N/A self _errback N/A N/A self consumedMessages N/A N/A self consumedMessages 1 N/A ack N/A N/A N/A N/A N/A N/A N/A self amqp chan basic_ack N/A message delivery_tag N/A N/A defer inlineCallbacks _errback N/A N/A self error N/A N/A N/A It appears that when closing a queue with the close() method it errbacks with
        a txamqp.queue.Closed exception, didnt find a clean way to stop consuming a queue
        without errbacking here so this is a workaround to make it clean, it can be considered
        as a @TODO requiring knowledge of the queue api behaviour
         N/A N/A N/A N/A error check Closed None N/A N/A N/A Error in _errback %s error N/A error N/A N/A ConsumeTestCase N/A ConsumeTools N/A test_consume_queue N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm.connector01 N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm.connector01 no_ack True consumer_tag qtag N/A N/A self queue N/A N/A N/A N/A N/A self amqp client queue qtag N/A N/A N/A N/A N/A N/A N/A N/A self queue get addCallback N/A self _callback N/A self queue addErrback N/A self _errback N/A N/A N/A waitFor 2 N/A N/A N/A N/A N/A self queue close N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks N/A PublishConsumeTestCase N/A ConsumeTools N/A test_simple_publish_consume N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm.connector01 N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm.connector01 no_ack True consumer_tag qtag N/A queue N/A N/A N/A N/A N/A self amqp client queue qtag N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback queue addErrback N/A self _errback N/A N/A N/A N/A N/A self amqp publish routing_key submit.sm.connector01 content N/A Content N/A self message N/A N/A N/A waitFor 2 N/A N/A N/A N/A queue close N/A N/A N/A N/A N/A self amqp disconnect N/A N/A N/A self assertEqual N/A self consumedMessages 1 N/A N/A defer inlineCallbacks test_simple_publish_consume_by_topic N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange messaging type topic N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm_all N/A N/A N/A N/A N/A N/A self amqp chan queue_bind queue submit.sm_all exchange messaging routing_key submit.sm.* N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm_all no_ack True consumer_tag qtag N/A queue N/A N/A N/A N/A N/A self amqp client queue qtag N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback queue addErrback N/A self _errback N/A N/A N/A N/A N/A self amqp publish exchange messaging routing_key submit.sm.connector01 content N/A Content N/A self message N/A N/A N/A waitFor 2 N/A N/A N/A N/A queue close N/A N/A N/A N/A N/A self amqp disconnect N/A N/A N/A self assertEqual N/A self consumedMessages 1 N/A N/A defer inlineCallbacks test_publish_consume_from_different_queues N/A N/A self N/A N/A N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm.connector01 N/A N/A N/A N/A N/A self amqp named_queue_declare queue deliver.sm.connector01 N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm.connector01 no_ack True consumer_tag submit_sm_consumer N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue deliver.sm.connector01 no_ack True consumer_tag deliver_sm_consumer N/A N/A self submit_sm_q N/A N/A N/A N/A N/A self amqp client queue submit_sm_consumer N/A N/A self deliver_sm_q N/A N/A N/A N/A N/A self amqp client queue deliver_sm_consumer N/A N/A N/A N/A N/A N/A N/A N/A self submit_sm_q get addCallback N/A self _callback N/A self submit_sm_q addErrback N/A self _errback N/A N/A N/A N/A N/A N/A N/A N/A self deliver_sm_q get addCallback N/A self _callback N/A self deliver_sm_q addErrback N/A self _errback N/A N/A N/A N/A N/A self amqp publish routing_key submit.sm.connector01 content N/A Content N/A self message N/A N/A N/A N/A N/A self amqp publish routing_key deliver.sm.connector01 content N/A Content N/A self message N/A N/A N/A waitFor 2 N/A N/A N/A N/A N/A self submit_sm_q close N/A N/A N/A N/A N/A self deliver_sm_q close N/A N/A N/A N/A N/A self amqp disconnect N/A N/A N/A self assertEqual N/A self consumedMessages 2 N/A N/A defer inlineCallbacks test_start_consuming_later N/A N/A self N/A N/A N/A Related to #67, will start consuming after publishing messages, this will imitate
        starting a connector with some pending messages for it N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange messaging type topic N/A consumerTag N/A lateConsumerTest-%s N/A str N/A N/A uuid uuid4 N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm.connector01 N/A N/A N/A N/A N/A N/A self amqp chan queue_bind queue submit.sm.connector01 exchange messaging routing_key submit.sm.* N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm.connector01 no_ack False consumer_tag consumerTag N/A queue N/A N/A N/A N/A N/A self amqp client queue consumerTag N/A i N/A range 5000 N/A N/A N/A N/A N/A N/A self amqp publish exchange messaging routing_key submit.sm.connector01 content N/A Content N/A str i N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback queue ack True addErrback N/A self _errback N/A N/A N/A waitFor 15 N/A N/A N/A N/A queue close N/A N/A N/A N/A N/A self amqp disconnect N/A N/A N/A self assertEqual N/A self consumedMessages 5000 N/A N/A defer inlineCallbacks N/A RejectAndRequeueTestCase N/A ConsumeTools N/A N/A rejectedMessages 0 N/A data N/A _callback_reject_once N/A N/A self message queue reject requeue N/A False 1 N/A N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback_reject_once queue reject requeue addErrback N/A self _errback N/A N/A reject N/A N/A N/A message content body N/A self data N/A N/A N/A self rejectedMessages N/A N/A self rejectedMessages 1 N/A N/A N/A N/A self data append N/A N/A message content body N/A N/A N/A N/A N/A N/A self amqp chan basic_reject delivery_tag N/A message delivery_tag requeue requeue N/A N/A N/A N/A N/A self data remove N/A N/A message content body N/A N/A self consumedMessages N/A N/A self consumedMessages 1 N/A N/A N/A N/A N/A N/A self amqp chan basic_ack N/A message delivery_tag N/A N/A defer inlineCallbacks _callback_reject_and_requeue_all N/A N/A self message queue requeue N/A 1 N/A N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback_reject_and_requeue_all queue requeue addErrback N/A self _errback N/A N/A self rejectedMessages N/A N/A self rejectedMessages 1 N/A N/A N/A N/A N/A N/A self amqp chan basic_reject delivery_tag N/A message delivery_tag requeue requeue N/A N/A defer inlineCallbacks test_consume_all_requeued_messages N/A N/A self N/A N/A N/A Related to #67, test for consuming all requeued messages N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange messaging type topic N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm_all_1 N/A N/A N/A N/A N/A N/A self amqp chan queue_bind queue submit.sm_all_1 exchange messaging routing_key submit.sm.* N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm_all_1 no_ack False consumer_tag qtag N/A queue N/A N/A N/A N/A N/A self amqp client queue qtag N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback_reject_once queue reject True addErrback N/A self _errback N/A i N/A range 3000 N/A N/A N/A N/A N/A N/A self amqp publish exchange messaging routing_key submit.sm.connector01 content N/A Content N/A str i N/A N/A N/A waitFor 20 N/A N/A N/A N/A queue close N/A N/A N/A N/A N/A self amqp disconnect N/A N/A N/A self assertEqual N/A self rejectedMessages 3000 N/A N/A N/A self assertEqual N/A self consumedMessages 3000 N/A N/A defer inlineCallbacks test_requeue_all_restart_then_reconsume N/A N/A self N/A N/A N/A Related to #67, Starting consuming with a  N/A N/A N/A N/A self connect N/A N/A N/A N/A N/A N/A self amqp chan exchange_declare exchange messaging type topic N/A N/A N/A N/A N/A self amqp named_queue_declare queue submit.sm_all_2 N/A N/A N/A N/A N/A N/A self amqp chan queue_bind queue submit.sm_all_2 exchange messaging routing_key submit.sm.* N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm_all_2 no_ack False consumer_tag qtag N/A queue N/A N/A N/A N/A N/A self amqp client queue qtag N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback_reject_and_requeue_all queue addErrback N/A self _errback N/A i N/A range 50 N/A N/A N/A N/A N/A N/A self amqp publish exchange messaging routing_key submit.sm.connector01 content N/A Content N/A str i N/A N/A N/A waitFor 2 N/A N/A N/A N/A N/A N/A self amqp chan basic_cancel consumer_tag qtag N/A N/A N/A self assertGreaterEqual N/A self rejectedMessages 50 N/A N/A N/A self assertEqual N/A self consumedMessages 0 N/A N/A N/A waitFor 2 N/A N/A N/A N/A N/A N/A self amqp chan basic_consume queue submit.sm_all_2 no_ack False consumer_tag qtag N/A queue N/A N/A N/A N/A N/A self amqp client queue qtag N/A N/A N/A N/A N/A N/A N/A queue get addCallback N/A self _callback queue addErrback N/A self _errback N/A N/A N/A waitFor 2 N/A N/A N/A N/A queue close N/A N/A N/A self assertEqual N/A self consumedMessages 50 N/A N/A N/A N/A N/A self amqp disconnect N/A N/A defer inlineCallbacks N/A