Skip to content

Instantly share code, notes, and snippets.

@susam

susam/gist:7173375

Created October 26, 2013 19:13
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save susam/7173375 to your computer and use it in GitHub Desktop.
Save susam/7173375 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.md

Logs for pika/pika#410

These logs were generated by the scripts mentioned at pika/pika#410.

sendlog.txt

DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_error of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
INFO:pika.adapters.base_connection:Connecting to 127.0.0.1:5672
DEBUG:pika.callback:Processing 0:Connection.Start
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>> for "0:Connection.Start"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 0:Connection.Tune
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>> for "0:Connection.Tune"
DEBUG:pika.connection:Creating a HeartbeatChecker: 600
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 0:Connection.OpenOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>> for "0:Connection.OpenOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_closed of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.adapters.blocking_connection:Opening channel 1
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_close of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_getempty of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_cancel of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 1:Channel.OpenOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>> for "1:Channel.OpenOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q1'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Queue.DeclareOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'queue': 'q1'} to {'queue': 'q1'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q1'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>> for "1:Queue.DeclareOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q2'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Queue.DeclareOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'queue': 'q2'} to {'queue': 'q2'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q2'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002034E48>> for "1:Queue.DeclareOk"
INFO:pika.adapters.blocking_connection:Closing connection (200): Normal shutdown
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_closed of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 0:Connection.CloseOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_closed of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_closed of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>> for "0:Connection.CloseOk"
WARNING:pika.adapters.base_connection:Unknown state on disconnect: 0
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
WARNING:pika.adapters.base_connection:Unknown state on disconnect: 0
DEBUG:pika.callback:Incremented callback reference counter: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000026A6DD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 2}

recvlog.txt

DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_error of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
INFO:pika.adapters.base_connection:Connecting to 127.0.0.1:5672
DEBUG:pika.callback:Processing 0:Connection.Start
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>> for "0:Connection.Start"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 0:Connection.Tune
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>> for "0:Connection.Tune"
DEBUG:pika.connection:Creating a HeartbeatChecker: 600
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 0:Connection.OpenOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>> for "0:Connection.OpenOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_closed of <pika.adapters.blocking_connection.BlockingConnection object at 0x00000000025DADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.adapters.blocking_connection:Opening channel 1
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_close of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_getempty of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_cancel of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 1:Channel.OpenOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Channel.OpenOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q1'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Queue.DeclareOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'queue': 'q1'} to {'queue': 'q1'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q1'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Queue.DeclareOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q2'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Queue.DeclareOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'queue': 'q2'} to {'queue': 'q2'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q2'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Queue.DeclareOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'consumer_tag': 'ctag1.0'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Basic.ConsumeOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'consumer_tag': 'ctag1.0'} to {'consumer_tag': 'ctag1.0'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'consumer_tag': 'ctag1.0'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Basic.ConsumeOk"
DEBUG:pika.channel:Called with <METHOD(['frame_type=1', 'channel_number=1', "method=<Basic.Deliver(['consumer_tag=ctag1.0', 'redelivered=False', 'routing_key=q1', 'delivery_tag=1', 'exchange='])>"])>, <Header(['frame_type=2', 'channel_number=1', 'properties=<BasicProperties>', 'body_size=13'])>, 'q1: message 0'
DEBUG:pika.channel:Called with <METHOD(['frame_type=1', 'channel_number=1', "method=<Basic.Deliver(['consumer_tag=ctag1.0', 'redelivered=False', 'routing_key=q1', 'delivery_tag=2', 'exchange='])>"])>, <Header(['frame_type=2', 'channel_number=1', 'properties=<BasicProperties>', 'body_size=13'])>, 'q1: message 1'
DEBUG:pika.channel:Called with <METHOD(['frame_type=1', 'channel_number=1', "method=<Basic.Deliver(['consumer_tag=ctag1.0', 'redelivered=False', 'routing_key=q1', 'delivery_tag=3', 'exchange='])>"])>, <Header(['frame_type=2', 'channel_number=1', 'properties=<BasicProperties>', 'body_size=13'])>, 'q1: message 2'
Traceback (most recent call last):
  File "recv.py", line 17, in <module>
    channel.basic_consume(print_data, queue='q1')
  File "build\bdist.win-amd64\egg\pika\channel.py", line 220, in basic_consume
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 1104, in _rpc
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 1124, in _send_method
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 215, in process_data_events
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 327, in _handle_read
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 66, in ready
KeyboardInterrupt

recvlog2.txt

DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_error of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
INFO:pika.adapters.base_connection:Connecting to 127.0.0.1:5672
DEBUG:pika.callback:Processing 0:Connection.Start
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_start of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>> for "0:Connection.Start"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 0:Connection.Tune
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_tune of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>> for "0:Connection.Tune"
DEBUG:pika.connection:Creating a HeartbeatChecker: 600
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 0:Connection.OpenOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingConnection._on_connection_open of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>> for "0:Connection.OpenOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingConnection._on_connection_closed of <pika.adapters.blocking_connection.BlockingConnection object at 0x000000000275ADD8>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.adapters.blocking_connection:Opening channel 1
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_close of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_getempty of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_cancel of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': False, 'arguments': None}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 1}
DEBUG:pika.callback:Processing 1:Channel.OpenOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': None, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Channel.OpenOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q1'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Queue.DeclareOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'queue': 'q1'} to {'queue': 'q1'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q1'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Queue.DeclareOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q2'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Queue.DeclareOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'queue': 'q2'} to {'queue': 'q2'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'queue': 'q2'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Queue.DeclareOk"
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'consumer_tag': 'ctag1.0'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Basic.ConsumeOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'consumer_tag': 'ctag1.0'} to {'consumer_tag': 'ctag1.0'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'consumer_tag': 'ctag1.0'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Basic.ConsumeOk"
DEBUG:pika.channel:Discarding frame <METHOD(['frame_type=1', 'channel_number=1', "method=<Basic.ConsumeOk(['consumer_tag=ctag1.0'])>"])>
DEBUG:pika.callback:Added: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'consumer_tag': 'ctag1.1'}, 'calls': 1}
DEBUG:pika.callback:Processing 1:Basic.ConsumeOk
DEBUG:pika.callback:Processing use of oneshot callback
DEBUG:pika.callback:0 registered uses left
DEBUG:pika.callback:Comparing {'consumer_tag': 'ctag1.1'} to {'consumer_tag': 'ctag1.1'}
DEBUG:pika.callback:Removing callback #0: {'callback': <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>>, 'only': None, 'one_shot': True, 'arguments': {'consumer_tag': 'ctag1.1'}, 'calls': 0}
DEBUG:pika.callback:Calling <bound method BlockingChannel._on_rpc_complete of <pika.adapters.blocking_connection.BlockingChannel object at 0x0000000002014E48>> for "1:Basic.ConsumeOk"
DEBUG:pika.channel:Called with <METHOD(['frame_type=1', 'channel_number=1', "method=<Basic.Deliver(['consumer_tag=ctag1.1', 'redelivered=False', 'routing_key=q2', 'delivery_tag=1', 'exchange='])>"])>, <Header(['frame_type=2', 'channel_number=1', 'properties=<BasicProperties>', 'body_size=13'])>, 'q2: message 0'
DEBUG:pika.channel:Called with <METHOD(['frame_type=1', 'channel_number=1', "method=<Basic.Deliver(['consumer_tag=ctag1.1', 'redelivered=False', 'routing_key=q2', 'delivery_tag=2', 'exchange='])>"])>, <Header(['frame_type=2', 'channel_number=1', 'properties=<BasicProperties>', 'body_size=13'])>, 'q2: message 1'
DEBUG:pika.channel:Called with <METHOD(['frame_type=1', 'channel_number=1', "method=<Basic.Deliver(['consumer_tag=ctag1.1', 'redelivered=False', 'routing_key=q2', 'delivery_tag=3', 'exchange='])>"])>, <Header(['frame_type=2', 'channel_number=1', 'properties=<BasicProperties>', 'body_size=13'])>, 'q2: message 2'
Traceback (most recent call last):
  File "recv.py", line 18, in <module>
    channel.basic_consume(print_data, queue='q2')
  File "build\bdist.win-amd64\egg\pika\channel.py", line 220, in basic_consume
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 1104, in _rpc
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 1124, in _send_method
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 215, in process_data_events
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 327, in _handle_read
  File "build\bdist.win-amd64\egg\pika\adapters\blocking_connection.py", line 66, in ready
KeyboardInterrupt
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment