Skip to content

Instantly share code, notes, and snippets.

@bmizerany

bmizerany/gist:15648

Created October 8, 2008 23:04
Show Gist options
  • Save bmizerany/15648 to your computer and use it in GitHub Desktop.
Save bmizerany/15648 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
["connected"]
["receive",
#<AMQP::Frame::Method:0x54702c
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Start:0x545c18
@debug=1,
@locales="en_US",
@mechanisms="PLAIN AMQPLAIN",
@server_properties=
{:copyright=>
"Copyright (C) 2007-2008 LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd.",
:version=>"1.4.0",
:product=>"RabbitMQ",
:information=>"Licensed under the MPL. See http://www.rabbitmq.com/",
:platform=>"Erlang/OTP"},
@version_major=8,
@version_minor=0>>]
["send",
#<AMQP::Frame::Method:0x3533b0
@channel=0,
@payload=
#<AMQP::Protocol::Connection::StartOk:0x35564c
@client_properties=
{:version=>"0.5.9",
:product=>"AMQP",
:information=>"http://github.com/tmm1/amqp",
:platform=>"Ruby/EventMachine"},
@debug=1,
@locale="en_US",
@mechanism="AMQPLAIN",
@response={:PASSWORD=>"guest", :LOGIN=>"guest"}>>]
["receive",
#<AMQP::Frame::Method:0x12f8ff4
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Tune:0x12f8c5c
@channel_max=0,
@debug=1,
@frame_max=131072,
@heartbeat=0>>]
["send",
#<AMQP::Frame::Method:0x12eeff4
@channel=0,
@payload=
#<AMQP::Protocol::Connection::TuneOk:0x12ef1fc
@channel_max=0,
@debug=1,
@frame_max=131072,
@heartbeat=0>>]
["send",
#<AMQP::Frame::Method:0x12e4ef0
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Open:0x12e5120
@capabilities="",
@debug=1,
@insist=nil,
@virtual_host="/">>]
["receive",
#<AMQP::Frame::Method:0x12da478
@channel=0,
@payload=
#<AMQP::Protocol::Connection::OpenOk:0x12da0e0
@debug=1,
@known_hosts="blake-2.local:5672">>]
["send",
#<AMQP::Frame::Method:0x12d2250
@channel=1,
@payload=
#<AMQP::Protocol::Channel::Open:0x12d255c @debug=1, @out_of_band=nil>>]
["send",
#<AMQP::Frame::Method:0x12ca410
@channel=2,
@payload=
#<AMQP::Protocol::Channel::Open:0x12ca71c @debug=1, @out_of_band=nil>>]
["receive",
#<AMQP::Frame::Method:0x12c2030
@channel=2,
@payload=#<AMQP::Protocol::Channel::OpenOk:0x12c1c98 @debug=1>>]
["send",
#<AMQP::Frame::Method:0x12bb834
@channel=2,
@payload=
#<AMQP::Protocol::Access::Request:0x12bbce4
@active=true,
@debug=1,
@exclusive=nil,
@passive=nil,
@read=true,
@realm="/data",
@write=true>>]
["receive",
#<AMQP::Frame::Method:0x12ae490
@channel=1,
@payload=#<AMQP::Protocol::Channel::OpenOk:0x12ae0f8 @debug=1>>]
["send",
#<AMQP::Frame::Method:0x12a7ca8
@channel=1,
@payload=
#<AMQP::Protocol::Access::Request:0x12a8158
@active=true,
@debug=1,
@exclusive=nil,
@passive=nil,
@read=true,
@realm="/data",
@write=true>>]
["receive",
#<AMQP::Frame::Method:0x129a5f8
@channel=1,
@payload=
#<AMQP::Protocol::Access::RequestOk:0x129a260 @debug=1, @ticket=101>>]
["send",
#<AMQP::Frame::Method:0x12926b4
@channel=1,
@payload=
#<AMQP::Protocol::Queue::Declare:0x1292ccc
@arguments=nil,
@auto_delete=nil,
@debug=1,
@durable=nil,
@exclusive=nil,
@nowait=true,
@passive=nil,
@queue="hash table node",
@ticket=101>>]
["send",
#<AMQP::Frame::Method:0x12834c0
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Consume:0x1283a10
@consumer_tag="hash table node",
@debug=1,
@exclusive=nil,
@no_ack=true,
@no_local=nil,
@nowait=true,
@queue="hash table node",
@ticket=101>>]
["receive",
#<AMQP::Frame::Method:0x12753c0
@channel=2,
@payload=
#<AMQP::Protocol::Access::RequestOk:0x1275028 @debug=1, @ticket=101>>]
["send",
#<AMQP::Frame::Method:0x126d47c
@channel=2,
@payload=
#<AMQP::Protocol::Queue::Declare:0x126da94
@arguments=nil,
@auto_delete=nil,
@debug=1,
@durable=nil,
@exclusive=nil,
@nowait=true,
@passive=nil,
@queue="random identifier 35955377141",
@ticket=101>>]
["send",
#<AMQP::Frame::Method:0x125e288
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Consume:0x125e7d8
@consumer_tag="random identifier 35955377141",
@debug=1,
@exclusive=nil,
@no_ack=true,
@no_local=nil,
@nowait=true,
@queue="random identifier 35955377141",
@ticket=101>>]
["send",
#<AMQP::Frame::Method:0x12503b8
@channel=2,
@payload=
#<AMQP::Protocol::Queue::Declare:0x12509d0
@arguments=nil,
@auto_delete=nil,
@debug=1,
@durable=nil,
@exclusive=nil,
@nowait=true,
@passive=nil,
@queue="hash table node",
@ticket=101>>]
["send",
#<AMQP::Frame::Method:0x1241098
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Publish:0x12416d8
@debug=1,
@exchange="",
@immediate=nil,
@mandatory=nil,
@routing_key="hash table node",
@ticket=101>>]
["send",
#<AMQP::Frame::Header:0x1235040
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x12413e0
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 573813623308",
:priority=>0,
:delivery_mode=>1,
:reply_to=>nil},
@size=30,
@weight=0>>]
["send",
#<AMQP::Frame::Body:0x124132c
@channel=2,
@payload="\004\b[\b:\bset:\bnowu:\tTime\r\027%\e\200\231\362m\020">]
["send",
#<AMQP::Frame::Method:0x121d5f8
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Publish:0x121dc38
@debug=1,
@exchange="",
@immediate=nil,
@mandatory=nil,
@routing_key="hash table node",
@ticket=101>>]
["send",
#<AMQP::Frame::Header:0x12115a0
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x121d940
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 623017044257",
:priority=>0,
:delivery_mode=>1,
:reply_to=>"random identifier 35955377141"},
@size=14,
@weight=0>>]
["send",
#<AMQP::Frame::Body:0x121d88c @channel=2, @payload="\004\b[\a:\bget:\bnow">]
["send",
#<AMQP::Frame::Method:0x11f9d24
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Publish:0x11fa364
@debug=1,
@exchange="",
@immediate=nil,
@mandatory=nil,
@routing_key="hash table node",
@ticket=101>>]
["send",
#<AMQP::Frame::Header:0x11edccc
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x11fa06c
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 828002940540",
:priority=>0,
:delivery_mode=>1,
:reply_to=>nil},
@size=16,
@weight=0>>]
["send",
#<AMQP::Frame::Body:0x11f9fb8
@channel=2,
@payload="\004\b[\b:\bset:\bonei\006">]
["send",
#<AMQP::Frame::Method:0x11d6284
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Publish:0x11d68c4
@debug=1,
@exchange="",
@immediate=nil,
@mandatory=nil,
@routing_key="hash table node",
@ticket=101>>]
["send",
#<AMQP::Frame::Header:0x11ca22c
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x11d65cc
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 519951827846",
:priority=>0,
:delivery_mode=>1,
:reply_to=>"random identifier 35955377141"},
@size=10,
@weight=0>>]
["send",
#<AMQP::Frame::Body:0x11d6518 @channel=2, @payload="\004\b[\006:\tkeys">]
["receive",
#<AMQP::Frame::Method:0x11b2730
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Deliver:0x11b2398
@consumer_tag="hash table node",
@debug=1,
@delivery_tag=1,
@exchange="",
@redelivered=false,
@routing_key="hash table node">>]
["receive",
#<AMQP::Frame::Header:0x11a5f1c
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x11a5e90
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 573813623308",
:priority=>0,
:delivery_mode=>1},
@size=30,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x1194334
@channel=1,
@payload="\004\b[\b:\bset:\bnowu:\tTime\r\027%\e\200\231\362m\020">]
["HashTable", :set, {:now=>Wed Oct 08 16:04:06 -0700 2008}]
["receive",
#<AMQP::Frame::Method:0x118ed30
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Deliver:0x118e998
@consumer_tag="hash table node",
@debug=1,
@delivery_tag=2,
@exchange="",
@redelivered=false,
@routing_key="hash table node">>]
["receive",
#<AMQP::Frame::Header:0x118251c
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x1182490
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 623017044257",
:priority=>0,
:delivery_mode=>1,
:reply_to=>"random identifier 35955377141"},
@size=14,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x116f188 @channel=1, @payload="\004\b[\a:\bget:\bnow">]
["HashTable", :get, :now]
["send",
#<AMQP::Frame::Method:0x1169d78
@channel=1,
@payload=
#<AMQP::Protocol::Queue::Declare:0x116a390
@arguments=nil,
@auto_delete=nil,
@debug=1,
@durable=nil,
@exclusive=nil,
@nowait=true,
@passive=nil,
@queue="random identifier 35955377141",
@ticket=101>>]
["send",
#<AMQP::Frame::Method:0x115a774
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Publish:0x115adb4
@debug=1,
@exchange="",
@immediate=nil,
@mandatory=nil,
@routing_key="random identifier 35955377141",
@ticket=101>>]
["send",
#<AMQP::Frame::Header:0x114e71c
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x115aabc
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 623017044257",
:priority=>0,
:delivery_mode=>1},
@size=18,
@weight=0>>]
["send",
#<AMQP::Frame::Body:0x115aa08
@channel=1,
@payload="\004\bu:\tTime\r\027%\e\200\231\362m\020">]
["receive",
#<AMQP::Frame::Method:0x1138278
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Deliver:0x1137ee0
@consumer_tag="hash table node",
@debug=1,
@delivery_tag=3,
@exchange="",
@redelivered=false,
@routing_key="hash table node">>]
["receive",
#<AMQP::Frame::Header:0x112ba64
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x112b9d8
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 828002940540",
:priority=>0,
:delivery_mode=>1},
@size=16,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x1119e7c
@channel=1,
@payload="\004\b[\b:\bset:\bonei\006">]
["HashTable", :set, {:one=>1}]
["receive",
#<AMQP::Frame::Method:0x11148c8
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Deliver:0x1114530
@consumer_tag="hash table node",
@debug=1,
@delivery_tag=4,
@exchange="",
@redelivered=false,
@routing_key="hash table node">>]
["receive",
#<AMQP::Frame::Header:0x11080b4
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x1108028
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 519951827846",
:priority=>0,
:delivery_mode=>1,
:reply_to=>"random identifier 35955377141"},
@size=10,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x5ee32c @channel=1, @payload="\004\b[\006:\tkeys">]
["HashTable", :keys]
["send",
#<AMQP::Frame::Method:0x5d9bfc
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Publish:0x5da340
@debug=1,
@exchange="",
@immediate=nil,
@mandatory=nil,
@routing_key="random identifier 35955377141",
@ticket=101>>]
["send",
#<AMQP::Frame::Header:0x5ac4cc
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x5d9fa8
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 519951827846",
:priority=>0,
:delivery_mode=>1},
@size=14,
@weight=0>>]
["send",
#<AMQP::Frame::Body:0x5d9ee0 @channel=1, @payload="\004\b[\a:\bnow:\bone">]
["receive",
#<AMQP::Frame::Method:0x548d8c
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Deliver:0x5480d0
@consumer_tag="random identifier 35955377141",
@debug=1,
@delivery_tag=1,
@exchange="",
@redelivered=false,
@routing_key="random identifier 35955377141">>]
["receive",
#<AMQP::Frame::Header:0x51d63c
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x51d574
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 623017044257",
:priority=>0,
:delivery_mode=>1},
@size=18,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x394450
@channel=2,
@payload="\004\bu:\tTime\r\027%\e\200\231\362m\020">]
["client", {:eql?=>true, :now=>Wed Oct 08 16:04:06 -0700 2008}]
["receive",
#<AMQP::Frame::Method:0x378458
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Deliver:0x37706c
@consumer_tag="random identifier 35955377141",
@debug=1,
@delivery_tag=2,
@exchange="",
@redelivered=false,
@routing_key="random identifier 35955377141">>]
["receive",
#<AMQP::Frame::Header:0x240a4
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x23ff0
@klass=AMQP::Protocol::Basic,
@properties=
{:content_type=>"application/octet-stream",
:message_id=>"random message id 519951827846",
:priority=>0,
:delivery_mode=>1},
@size=14,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x12f24d8 @channel=2, @payload="\004\b[\a:\bnow:\bone">]
["client", {:keys=>[:now, :one]}]
["disconnected"]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment