Module Import alias Import alias ImportFrom alias ImportFrom alias Import alias Import alias Import alias ImportFrom alias alias alias ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr TupleLoad TupleLoad BinOpAdd Str AttributeLoad Call AttributeLoad NameLoad attr attr NameLoad TupleLoad BinOpAdd Str AttributeLoad Call AttributeLoad NameLoad attr attr NameLoad TupleLoad BinOpAdd Str AttributeLoad Call AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr ListLoad For TupleStore NameStore NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr keyword IfExp UnaryOpNot NameLoad AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword Dict Str BinOpMult AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr If CompareEq Call NameLoad AttributeLoad NameLoad attr Num body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr keyword SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index Num Index Num keyword NameLoad keyword NameLoad orelse If CompareEq Call NameLoad AttributeLoad NameLoad attr Num body Expr Call AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr Call NameLoad GeneratorExp SubscriptLoad NameLoad Index Num comprehension NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr BinOpAdd BinOpAdd AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad Call AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body For NameStore Call NameLoad Num Num body Assign NameStore Call AttributeLoad Str attr AttributeLoad AttributeLoad NameLoad attr attr NameLoad Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr BinOpAdd BinOpAdd AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad Call AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str Assign NameStore Str Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr BinOpAdd BinOpAdd AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad Call AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad AttributeLoad NameLoad attr keyword NameLoad Raise Call NameLoad Str decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword Dict Str BinOpMult AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr BinOpAdd BinOpAdd AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad Call AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword Dict Str BinOpMult AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr BinOpAdd BinOpAdd AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad Call AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword Dict Str BinOpMult AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword Dict Str BinOpMult AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad AttributeLoad NameLoad attr keyword NameLoad Raise Call NameLoad Str decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Raise Call NameLoad Str decorator_list NameLoad decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Raise Call NameLoad Str decorator_list NameLoad decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr BinOpMod Str TupleLoad AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr NameLoad Call NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args defaults body Return Call AttributeLoad Str attr ListComp BinOpMod Str NameLoad comprehension NameStore Call NameLoad Num Num decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr NameLoad Call NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr BinOpMod Str TupleLoad AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr NameLoad Call NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam defaults vararg kwarg body Assign AttributeStore AttributeLoad NameLoad attr attr Call NameLoad Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam defaults vararg kwarg body Assign AttributeStore AttributeLoad NameLoad attr attr Num Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr TupleLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Num Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr TupleLoad NameLoad NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Str FunctionDef arguments args NameParam defaults vararg kwarg body Assign AttributeStore AttributeLoad NameLoad attr attr Num Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr TupleLoad Num Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Num Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad AttributeLoad NameLoad attr attr Num Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Num AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr TupleLoad NameLoad NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list decorator_list
N/A N/A time N/A uuid pika spec pika.compat as_bytes N/A pika.connection N/A pika.frame N/A pika.spec async_test_base AsyncTestCase BoundQueueTestCase AsyncAdapters TestA_Connect N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Connect, open channel and disconnect begin N/A N/A self channel N/A N/A N/A N/A N/A self stop N/A N/A TestConfirmSelect N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Receive confirmation of Confirm.Select begin N/A N/A self channel N/A N/A N/A N/A channel _on_selectok N/A self on_complete N/A N/A N/A channel confirm_delivery N/A on_complete N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Confirm SelectOk N/A N/A N/A self stop N/A N/A TestBlockingNonBlockingBlockingRPCWontStall N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Verify that a sequence of blocking, non-blocking, blocking RPC requests won't stall begin N/A N/A self channel N/A N/A N/A N/A self _expected_queue_params N/A N/A N/A blocking-non-blocking-stall-check- N/A N/A N/A uuid uuid1 hex False N/A N/A blocking-non-blocking-stall-check- N/A N/A N/A uuid uuid1 hex True N/A N/A blocking-non-blocking-stall-check- N/A N/A N/A uuid uuid1 hex False N/A N/A self _declared_queue_names N/A N/A N/A queue nowait N/A self _expected_queue_params N/A N/A N/A N/A channel queue_declare callback N/A N/A nowait N/A self _queue_declare_ok_cb None queue queue auto_delete True nowait nowait arguments N/A x-expires N/A N/A self TIMEOUT 1000 N/A _queue_declare_ok_cb N/A N/A self declare_ok_frame N/A N/A N/A N/A N/A N/A self _declared_queue_names append N/A N/A declare_ok_frame method queue N/A N/A N/A len N/A self _declared_queue_names 2 N/A N/A N/A N/A N/A self channel queue_declare callback N/A self _queue_declare_ok_cb queue N/A N/A N/A self _expected_queue_params N/A 1 N/A 0 passive True nowait False N/A N/A N/A N/A len N/A self _declared_queue_names 3 N/A N/A N/A N/A self assertSequenceEqual N/A sorted N/A self _declared_queue_names N/A sorted N/A N/A item N/A 0 N/A item N/A self _expected_queue_params N/A N/A N/A self stop N/A N/A TestConsumeCancel N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Consume and cancel begin N/A N/A self channel N/A N/A N/A N/A self queue_name N/A N/A N/A N/A self __class__ __name__ : N/A N/A N/A uuid uuid1 hex N/A N/A N/A channel queue_declare N/A self on_queue_declared queue N/A self queue_name N/A on_queue_declared N/A N/A self frame N/A N/A N/A i N/A range 0 100 N/A N/A msg_body N/A N/A {0}:{1}:{2} format N/A N/A self __class__ __name__ i N/A N/A time time N/A N/A N/A N/A self channel basic_publish N/A self queue_name msg_body N/A N/A self ctag N/A N/A N/A self channel basic_consume N/A self on_message queue N/A self queue_name no_ack True N/A on_message N/A N/A self _channel _frame _header body N/A N/A N/A N/A N/A N/A self channel basic_cancel N/A self on_cancel N/A self ctag N/A on_cancel N/A N/A self _frame N/A N/A N/A N/A N/A N/A self channel queue_delete N/A self on_deleted N/A self queue_name N/A on_deleted N/A N/A self _frame N/A N/A N/A N/A N/A self stop N/A N/A TestExchangeDeclareAndDelete N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Create and delete and exchange N/A X_TYPE direct begin N/A N/A self channel N/A N/A N/A N/A self name N/A N/A N/A N/A self __class__ __name__ : N/A N/A N/A uuid uuid1 hex N/A N/A N/A channel exchange_declare N/A self on_exchange_declared N/A self name exchange_type N/A self X_TYPE passive False durable False auto_delete True N/A on_exchange_declared N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Exchange DeclareOk N/A N/A N/A N/A self channel exchange_delete N/A self on_exchange_delete N/A self name N/A on_exchange_delete N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Exchange DeleteOk N/A N/A N/A self stop N/A N/A TestExchangeRedeclareWithDifferentValues N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION should close chan: re-declared exchange w/ diff params N/A X_TYPE1 direct N/A X_TYPE2 topic begin N/A N/A self channel N/A N/A N/A N/A self name N/A N/A N/A N/A self __class__ __name__ : N/A N/A N/A uuid uuid1 hex N/A N/A N/A N/A self channel add_on_close_callback N/A self on_channel_closed N/A N/A N/A channel exchange_declare N/A self on_exchange_declared N/A self name exchange_type N/A self X_TYPE1 passive False durable False auto_delete True N/A on_cleanup_channel N/A N/A self channel N/A N/A N/A N/A N/A channel exchange_delete None N/A self name nowait True N/A N/A N/A self stop N/A on_channel_closed N/A N/A self channel reply_code reply_text N/A N/A N/A N/A N/A N/A self connection channel N/A self on_cleanup_channel N/A on_exchange_declared N/A N/A self frame N/A N/A N/A N/A N/A N/A self channel exchange_declare N/A self on_bad_result N/A self name exchange_type N/A self X_TYPE2 passive False durable False auto_delete True N/A on_bad_result N/A N/A self frame N/A N/A N/A N/A N/A N/A self channel exchange_delete None N/A self name nowait True N/A N/A AssertionError Should not have received a Queue.DeclareOk N/A N/A TestQueueDeclareAndDelete N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Create and delete a queue begin N/A N/A self channel N/A N/A N/A N/A N/A channel queue_declare N/A self on_queue_declared passive False durable False exclusive True auto_delete False nowait False arguments N/A x-expires N/A N/A self TIMEOUT 1000 N/A on_queue_declared N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Queue DeclareOk N/A N/A N/A N/A self channel queue_delete N/A self on_queue_delete N/A N/A frame method queue N/A on_queue_delete N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Queue DeleteOk N/A N/A N/A self stop N/A N/A TestQueueNameDeclareAndDelete N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Create and delete a named queue begin N/A N/A self channel N/A N/A N/A N/A self _q_name N/A N/A N/A N/A self __class__ __name__ : N/A N/A N/A uuid uuid1 hex N/A N/A N/A channel queue_declare N/A self on_queue_declared N/A self _q_name passive False durable False exclusive True auto_delete True nowait False arguments N/A x-expires N/A N/A self TIMEOUT 1000 N/A on_queue_declared N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Queue DeclareOk N/A N/A N/A self assertEqual N/A N/A frame method queue N/A self _q_name N/A N/A N/A N/A self channel queue_delete N/A self on_queue_delete N/A N/A frame method queue N/A on_queue_delete N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Queue DeleteOk N/A N/A N/A self stop N/A N/A TestQueueRedeclareWithDifferentValues N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Should close chan: re-declared queue w/ diff params begin N/A N/A self channel N/A N/A N/A N/A self _q_name N/A N/A N/A N/A self __class__ __name__ : N/A N/A N/A uuid uuid1 hex N/A N/A N/A N/A self channel add_on_close_callback N/A self on_channel_closed N/A N/A N/A channel queue_declare N/A self on_queue_declared N/A self _q_name passive False durable False exclusive True auto_delete True nowait False arguments N/A x-expires N/A N/A self TIMEOUT 1000 N/A on_channel_closed N/A N/A self channel reply_code reply_text N/A N/A N/A N/A N/A self stop N/A on_queue_declared N/A N/A self frame N/A N/A N/A N/A N/A N/A self channel queue_declare N/A self on_bad_result N/A self _q_name passive False durable True exclusive False auto_delete True nowait False arguments N/A x-expires N/A N/A self TIMEOUT 1000 N/A on_bad_result N/A N/A self frame N/A N/A N/A N/A N/A N/A self channel queue_delete None N/A self _q_name nowait True N/A N/A AssertionError Should not have received a Queue.DeclareOk N/A N/A TestTX1_Select N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Receive confirmation of Tx.Select begin N/A N/A self channel N/A N/A N/A N/A N/A channel tx_select N/A self on_complete N/A on_complete N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Tx SelectOk N/A N/A N/A self stop N/A N/A TestTX2_Commit N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Start a transaction, and commit it begin N/A N/A self channel N/A N/A N/A N/A N/A channel tx_select N/A self on_selectok N/A on_selectok N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Tx SelectOk N/A N/A N/A N/A self channel tx_commit N/A self on_commitok N/A on_commitok N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Tx CommitOk N/A N/A N/A self stop N/A N/A TestTX2_CommitFailure N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Close the channel: commit without a TX begin N/A N/A self channel N/A N/A N/A N/A N/A N/A self channel add_on_close_callback N/A self on_channel_closed N/A N/A N/A N/A self channel tx_commit N/A self on_commitok N/A on_channel_closed N/A N/A self channel reply_code reply_text N/A N/A N/A N/A N/A self stop N/A on_selectok N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Tx SelectOk N/A on_commitok N/A N/A frame N/A N/A N/A N/A AssertionError Should not have received a Tx.CommitOk N/A staticmethod N/A TestTX3_Rollback N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Start a transaction, then rollback begin N/A N/A self channel N/A N/A N/A N/A N/A channel tx_select N/A self on_selectok N/A on_selectok N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Tx SelectOk N/A N/A N/A N/A self channel tx_rollback N/A self on_rollbackok N/A on_rollbackok N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Tx RollbackOk N/A N/A N/A self stop N/A N/A TestTX3_RollbackFailure N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Close the channel: rollback without a TX begin N/A N/A self channel N/A N/A N/A N/A N/A N/A self channel add_on_close_callback N/A self on_channel_closed N/A N/A N/A N/A self channel tx_rollback N/A self on_commitok N/A on_channel_closed N/A N/A self channel reply_code reply_text N/A N/A N/A N/A N/A self stop N/A on_commitok N/A N/A frame N/A N/A N/A N/A AssertionError Should not have received a Tx.RollbackOk N/A staticmethod N/A TestZ_PublishAndConsume N/A BoundQueueTestCase AsyncAdapters N/A N/A DESCRIPTION Publish a message and consume it on_ready N/A N/A self frame N/A N/A N/A N/A self ctag N/A N/A N/A self channel basic_consume N/A self on_message N/A self queue N/A N/A self msg_body N/A %s: %i N/A N/A N/A self __class__ __name__ N/A N/A time time N/A N/A N/A N/A self channel basic_publish N/A self exchange N/A self routing_key N/A self msg_body N/A on_cancelled N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Basic CancelOk N/A N/A N/A self stop N/A on_message N/A N/A self channel method header body N/A N/A N/A N/A N/A self assertIsInstance method N/A N/A spec Basic Deliver N/A N/A N/A self assertEqual body N/A as_bytes N/A self msg_body N/A N/A N/A N/A self channel basic_ack N/A method delivery_tag N/A N/A N/A N/A self channel basic_cancel N/A self on_cancelled N/A self ctag N/A N/A TestZ_PublishAndConsumeBig N/A BoundQueueTestCase AsyncAdapters N/A N/A DESCRIPTION Publish a big message and consume it _get_msg_body N/A N/A N/A N/A N/A N/A N/A join N/A N/A %s i N/A i N/A range 0 2097152 N/A staticmethod on_ready N/A N/A self frame N/A N/A N/A N/A self ctag N/A N/A N/A self channel basic_consume N/A self on_message N/A self queue N/A N/A self msg_body N/A N/A self _get_msg_body N/A N/A N/A N/A self channel basic_publish N/A self exchange N/A self routing_key N/A self msg_body N/A on_cancelled N/A N/A self frame N/A N/A N/A N/A N/A self assertIsInstance N/A frame method N/A N/A spec Basic CancelOk N/A N/A N/A self stop N/A on_message N/A N/A self channel method header body N/A N/A N/A N/A N/A self assertIsInstance method N/A N/A spec Basic Deliver N/A N/A N/A self assertEqual body N/A as_bytes N/A self msg_body N/A N/A N/A N/A self channel basic_ack N/A method delivery_tag N/A N/A N/A N/A self channel basic_cancel N/A self on_cancelled N/A self ctag N/A N/A TestZ_PublishAndGet N/A BoundQueueTestCase AsyncAdapters N/A N/A DESCRIPTION Publish a message and get it on_ready N/A N/A self frame N/A N/A N/A N/A self msg_body N/A %s: %i N/A N/A N/A self __class__ __name__ N/A N/A time time N/A N/A N/A N/A self channel basic_publish N/A self exchange N/A self routing_key N/A self msg_body N/A N/A N/A N/A self channel basic_get N/A self on_get N/A self queue N/A on_get N/A N/A self channel method header body N/A N/A N/A N/A N/A self assertIsInstance method N/A N/A spec Basic GetOk N/A N/A N/A self assertEqual body N/A as_bytes N/A self msg_body N/A N/A N/A N/A self channel basic_ack N/A method delivery_tag N/A N/A N/A self stop N/A N/A TestZ_AccessDenied N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Verify that access denied invokes on open error callback start N/A N/A self N/A args kwargs N/A N/A N/A N/A self parameters virtual_host N/A str N/A N/A uuid uuid4 N/A N/A self error_captured False N/A N/A N/A N/A super TestZ_AccessDenied self start args kwargs N/A N/A N/A self assertTrue N/A self error_captured N/A on_open_error N/A N/A self connection error N/A N/A N/A N/A self error_captured True N/A N/A N/A self stop N/A on_open N/A N/A self connection N/A N/A N/A N/A N/A N/A super TestZ_AccessDenied self on_open connection N/A N/A N/A self stop N/A N/A TestBlockedConnectionTimesOut N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Verify that blocked connection terminates on timeout start N/A N/A self N/A args kwargs N/A N/A N/A N/A self parameters blocked_connection_timeout 0.001 N/A N/A self on_closed_pair None N/A N/A N/A N/A super TestBlockedConnectionTimesOut self start args kwargs N/A N/A N/A self assertEqual N/A self on_closed_pair N/A N/A N/A N/A pika connection InternalCloseReasons BLOCKED_CONNECTION_TIMEOUT Blocked connection timeout expired N/A begin N/A N/A self channel N/A N/A N/A N/A N/A N/A channel connection _on_connection_blocked N/A N/A N/A pika frame Method 0 N/A N/A N/A N/A pika spec Connection Blocked Testing blocked connection timeout N/A on_closed N/A N/A self connection reply_code reply_text N/A N/A N/A called when the connection has finished closing N/A N/A self on_closed_pair N/A reply_code reply_text N/A N/A N/A N/A super TestBlockedConnectionTimesOut self on_closed connection reply_code reply_text N/A N/A TestBlockedConnectionUnblocks N/A AsyncTestCase AsyncAdapters N/A N/A DESCRIPTION Verify that blocked-unblocked connection closes normally start N/A N/A self N/A args kwargs N/A N/A N/A N/A self parameters blocked_connection_timeout 0.001 N/A N/A self on_closed_pair None N/A N/A N/A N/A super TestBlockedConnectionUnblocks self start args kwargs N/A N/A N/A self assertEqual N/A self on_closed_pair N/A 200 Normal shutdown N/A begin N/A N/A self channel N/A N/A N/A N/A N/A N/A channel connection _on_connection_blocked N/A N/A N/A pika frame Method 0 N/A N/A N/A N/A pika spec Connection Blocked Testing blocked connection unblocks N/A N/A N/A N/A channel connection _on_connection_unblocked N/A N/A N/A pika frame Method 0 N/A N/A N/A N/A pika spec Connection Unblocked N/A N/A N/A N/A channel connection add_timeout 0.005 N/A self on_cleanup_timer N/A on_cleanup_timer N/A N/A self N/A N/A N/A N/A N/A self stop N/A on_closed N/A N/A self connection reply_code reply_text N/A N/A N/A called when the connection has finished closing N/A N/A self on_closed_pair N/A reply_code reply_text N/A N/A N/A N/A super TestBlockedConnectionUnblocks self on_closed connection reply_code reply_text N/A N/A