Skip to content

Instantly share code, notes, and snippets.

@bmizerany
Created October 8, 2008 22:21
Show Gist options
  • Save bmizerany/15620 to your computer and use it in GitHub Desktop.
Save bmizerany/15620 to your computer and use it in GitHub Desktop.
blake-2:amqp blakemizerany$ ruby simple.rb
["connected"]
["receive",
#<AMQP::Frame::Method:0x5641cc
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Start:0x56278c
@debug=1,
@locales="en_US",
@mechanisms="PLAIN AMQPLAIN",
@server_properties=
{:version=>"1.4.0",
:platform=>"Erlang/OTP",
:copyright=>
"Copyright (C) 2007-2008 LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd.",
:product=>"RabbitMQ",
:information=>"Licensed under the MPL. See http://www.rabbitmq.com/"},
@version_major=8,
@version_minor=0>>]
["send",
#<AMQP::Frame::Method:0x51a57c
@channel=0,
@payload=
#<AMQP::Protocol::Connection::StartOk:0x51b01c
@client_properties=
{:version=>"0.1.0",
:platform=>"Ruby/EventMachine",
:product=>"AMQP",
:information=>"http://github.com/tmm1/amqp"},
@debug=1,
@locale="en_US",
@mechanism="AMQPLAIN",
@response={:LOGIN=>"guest", :PASSWORD=>"guest"}>>]
["receive",
#<AMQP::Frame::Method:0x1a388
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Tune:0x19244
@channel_max=0,
@debug=1,
@frame_max=131072,
@heartbeat=0>>]
["send",
#<AMQP::Frame::Method:0x12f94b8
@channel=0,
@payload=
#<AMQP::Protocol::Connection::TuneOk:0x12f96c0
@channel_max=0,
@debug=1,
@frame_max=131072,
@heartbeat=0>>]
["send",
#<AMQP::Frame::Method:0x12ef3dc
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Open:0x12ef60c
@capabilities="",
@debug=1,
@insist=nil,
@virtual_host="/">>]
["receive",
#<AMQP::Frame::Method:0x12e498c
@channel=0,
@payload=
#<AMQP::Protocol::Connection::OpenOk:0x12e45f4
@debug=1,
@known_hosts="blake-2.local:5672">>]
["send",
#<AMQP::Frame::Method:0x12dcafc
@channel=1,
@payload=
#<AMQP::Protocol::Channel::Open:0x12dcca0 @debug=1, @out_of_band=nil>>]
["receive",
#<AMQP::Frame::Method:0x12d4744
@channel=1,
@payload=#<AMQP::Protocol::Channel::OpenOk:0x12d43ac @debug=1>>]
["send",
#<AMQP::Frame::Method:0x12ce164
@channel=1,
@payload=
#<AMQP::Protocol::Access::Request:0x12ce4ac
@active=true,
@debug=1,
@exclusive=nil,
@passive=nil,
@read=true,
@realm="/data",
@write=true>>]
["receive",
#<AMQP::Frame::Method:0x12c0adc
@channel=1,
@payload=
#<AMQP::Protocol::Access::RequestOk:0x12c0744 @debug=1, @ticket=101>>]
["send",
#<AMQP::Frame::Method:0x12b8f44
@channel=1,
@payload=
#<AMQP::Protocol::Queue::Declare:0x12b93a4
@arguments=nil,
@auto_delete=true,
@debug=1,
@durable=nil,
@exclusive=nil,
@nowait=nil,
@passive=nil,
@queue="",
@ticket=101>>]
["receive",
#<AMQP::Frame::Method:0x12a9aa8
@channel=1,
@payload=
#<AMQP::Protocol::Queue::DeclareOk:0x12a9710
@consumer_count=0,
@debug=1,
@message_count=0,
@queue="amq.gen-gzqoArcMQPCSnErdfZPzdQ==">>]
["send",
#<AMQP::Frame::Method:0x129f8dc
@channel=1,
@payload=
#<AMQP::Protocol::Queue::Bind:0x129fc24
@arguments=nil,
@debug=1,
@exchange="",
@nowait=nil,
@queue="amq.gen-gzqoArcMQPCSnErdfZPzdQ==",
@routing_key="test_route",
@ticket=101>>]
["receive",
#<AMQP::Frame::Method:0x1291d18
@channel=1,
@payload=#<AMQP::Protocol::Queue::BindOk:0x1291980 @debug=1>>]
["send",
#<AMQP::Frame::Method:0x128b6ac
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Consume:0x128ba94
@consumer_tag=nil,
@debug=1,
@exclusive=nil,
@no_ack=true,
@no_local=nil,
@nowait=nil,
@queue="amq.gen-gzqoArcMQPCSnErdfZPzdQ==",
@ticket=101>>]
["receive",
#<AMQP::Frame::Method:0x127cfd0
@channel=1,
@payload=
#<AMQP::Protocol::Basic::ConsumeOk:0x127cc38
@consumer_tag="amq.ctag-+SCYfIgtipGxSOpPYOnO9A==",
@debug=1>>]
["send",
#<AMQP::Frame::Method:0x1275334
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Publish:0x127562c
@debug=1,
@exchange="",
@immediate=nil,
@mandatory=nil,
@routing_key="test_route",
@ticket=101>>]
["send",
#<AMQP::Frame::Header:0x12692b4
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x12693f4
@klass=AMQP::Protocol::Basic,
@properties=
{:priority=>0,
:content_type=>"application/octet-stream",
:delivery_mode=>1},
@size=15,
@weight=0>>]
["send", #<AMQP::Frame::Body:0x125924c @channel=1, @payload="this is a test!">]
["receive",
#<AMQP::Frame::Method:0x1254148
@channel=1,
@payload=
#<AMQP::Protocol::Basic::Deliver:0x1253db0
@consumer_tag="amq.ctag-+SCYfIgtipGxSOpPYOnO9A==",
@debug=1,
@delivery_tag=1,
@exchange="",
@redelivered=false,
@routing_key="test_route">>]
["receive",
#<AMQP::Frame::Header:0x1247c68
@channel=1,
@payload=
#<AMQP::Protocol::Header:0x1247bdc
@klass=AMQP::Protocol::Basic,
@properties=
{:priority=>0,
:content_type=>"application/octet-stream",
:delivery_mode=>1},
@size=15,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x12372f0 @channel=1, @payload="this is a test!">]
["disconnected"]
/Users/blakemizerany/.gems/gems/tmm1-amqp-0.5.9/lib/amqp/client.rb:72:in `connection_completed': Disconnected from server (AMQP::Error)
from /Users/blakemizerany/.gems/gems/tmm1-amqp-0.5.9/lib/amqp/client.rb:80:in `call'
from /Users/blakemizerany/.gems/gems/tmm1-amqp-0.5.9/lib/amqp/client.rb:80:in `unbind'
from /Users/blakemizerany/.gems/gems/eventmachine-0.12.2/lib/eventmachine.rb:1172:in `event_callback'
from /Users/blakemizerany/.gems/gems/eventmachine-0.12.2/lib/eventmachine.rb:233:in `release_machine'
from /Users/blakemizerany/.gems/gems/eventmachine-0.12.2/lib/eventmachine.rb:233:in `run'
from simple.rb:75
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment