Skip to content

Instantly share code, notes, and snippets.

@maheshmurthy

maheshmurthy/gist:1093039

Created July 19, 2011 16:51
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 maheshmurthy/1093039 to your computer and use it in GitHub Desktop.
Save maheshmurthy/1093039 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
["connected"]
["receive",
#<AMQP::Frame::Method:0x101176220
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Start:0x101175fc8
@debug=1,
@locales="en_US",
@mechanisms="PLAIN AMQPLAIN",
@server_properties=
{:product=>"RabbitMQ",
:version=>"2.4.1",
:capabilities=>{},
:information=>"Licensed under the MPL. See http://www.rabbitmq.com/",
:platform=>"Erlang/OTP",
:copyright=>"Copyright (C) 2007-2011 VMware, Inc."},
@version_major=8,
@version_minor=0>>]
["send",
#<AMQP::Frame::Method:0x10115bd58
@channel=0,
@payload=
#<AMQP::Protocol::Connection::StartOk:0x10115bec0
@client_properties=
{:product=>"AMQP",
:version=>"0.7.1",
:information=>"http://github.com/ruby-amqp/amqp",
:platform=>"Ruby/EventMachine"},
@debug=1,
@locale="en_US",
@mechanism="AMQPLAIN",
@response={:LOGIN=>"guest", :PASSWORD=>"guest"}>>]
["receive",
#<AMQP::Frame::Method:0x101144a68
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Tune:0x101144950
@channel_max=0,
@debug=1,
@frame_max=131072,
@heartbeat=0>>]
["send",
#<AMQP::Frame::Method:0x101139848
@channel=0,
@payload=
#<AMQP::Protocol::Connection::TuneOk:0x10113a1f8
@channel_max=0,
@debug=1,
@frame_max=131072,
@heartbeat=0>>]
["send",
#<AMQP::Frame::Method:0x10112e9e8
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Open:0x10112f438
@capabilities="",
@debug=1,
@insist=nil,
@virtual_host="/">>]
["receive",
#<AMQP::Frame::Method:0x101120f00
@channel=0,
@payload=
#<AMQP::Protocol::Connection::OpenOk:0x101120d70
@debug=1,
@known_hosts="">>]
[:sending,
#<AMQP::Protocol::Channel::Open:0x101118698 @debug=1, @out_of_band=nil>]
["send",
#<AMQP::Frame::Method:0x101110c40
@channel=1,
@payload=
#<AMQP::Protocol::Channel::Open:0x101118698 @debug=1, @out_of_band=nil>>]
["receive",
#<AMQP::Frame::Method:0x101108518
@channel=1,
@payload=#<AMQP::Protocol::Channel::OpenOk:0x1011083d8 @debug=1>>]
[:received,
#<AMQP::Frame::Method:0x101108518
@channel=1,
@payload=#<AMQP::Protocol::Channel::OpenOk:0x1011083d8 @debug=1>>]
[:sending,
#<AMQP::Protocol::Access::Request:0x1010fb638
@active=true,
@debug=1,
@exclusive=nil,
@passive=true,
@read=true,
@realm="/data",
@write=true>]
["send",
#<AMQP::Frame::Method:0x1010efcc0
@channel=1,
@payload=
#<AMQP::Protocol::Access::Request:0x1010fb638
@active=true,
@debug=1,
@exclusive=nil,
@passive=true,
@read=true,
@realm="/data",
@write=true>>]
["receive",
#<AMQP::Frame::Method:0x1010dd638
@channel=1,
@payload=
#<AMQP::Protocol::Access::RequestOk:0x1010dd4f8 @debug=1, @ticket=1>>]
[:received,
#<AMQP::Frame::Method:0x1010dd638
@channel=1,
@payload=
#<AMQP::Protocol::Access::RequestOk:0x1010dd4f8 @debug=1, @ticket=1>>]
[:sending,
#<AMQP::Protocol::Channel::Open:0x1010ccc48 @debug=1, @out_of_band=nil>]
["send",
#<AMQP::Frame::Method:0x1010c7c70
@channel=2,
@payload=
#<AMQP::Protocol::Channel::Open:0x1010ccc48 @debug=1, @out_of_band=nil>>]
["receive",
#<AMQP::Frame::Method:0x1010bdb58
@channel=2,
@payload=#<AMQP::Protocol::Channel::OpenOk:0x1010bda40 @debug=1>>]
[:received,
#<AMQP::Frame::Method:0x1010bdb58
@channel=2,
@payload=#<AMQP::Protocol::Channel::OpenOk:0x1010bda40 @debug=1>>]
[:sending,
#<AMQP::Protocol::Access::Request:0x1010b4558
@active=true,
@debug=1,
@exclusive=nil,
@passive=true,
@read=true,
@realm="/data",
@write=true>]
["send",
#<AMQP::Frame::Method:0x1010add48
@channel=2,
@payload=
#<AMQP::Protocol::Access::Request:0x1010b4558
@active=true,
@debug=1,
@exclusive=nil,
@passive=true,
@read=true,
@realm="/data",
@write=true>>]
["receive",
#<AMQP::Frame::Method:0x1010a3460
@channel=2,
@payload=
#<AMQP::Protocol::Access::RequestOk:0x1010a3320 @debug=1, @ticket=1>>]
[:received,
#<AMQP::Frame::Method:0x1010a3460
@channel=2,
@payload=
#<AMQP::Protocol::Access::RequestOk:0x1010a3320 @debug=1, @ticket=1>>]
[:sending,
#<AMQP::Protocol::Queue::Declare:0x101098600
@arguments=nil,
@auto_delete=nil,
@debug=1,
@durable=nil,
@exclusive=nil,
@nowait=true,
@passive=true,
@queue="async_code_execution",
@ticket=1>]
["send",
#<AMQP::Frame::Method:0x1010908d8
@channel=2,
@payload=
#<AMQP::Protocol::Queue::Declare:0x101098600
@arguments=nil,
@auto_delete=nil,
@debug=1,
@durable=nil,
@exclusive=nil,
@nowait=true,
@passive=true,
@queue="async_code_execution",
@ticket=1>>]
[:sending,
#<AMQP::Protocol::Basic::Get:0x1010850c8
@debug=1,
@no_ack=nil,
@queue="async_code_execution",
@ticket=1>]
["send",
#<AMQP::Frame::Method:0x101080370
@channel=2,
@payload=
#<AMQP::Protocol::Basic::Get:0x1010850c8
@debug=1,
@no_ack=nil,
@queue="async_code_execution",
@ticket=1>>]
["receive",
#<AMQP::Frame::Method:0x1010775e0
@channel=2,
@payload=
#<AMQP::Protocol::Basic::GetOk:0x1010774c8
@debug=1,
@delivery_tag=1,
@exchange="",
@message_count=91,
@redelivered=true,
@routing_key="async_code_execution">>]
[:received,
#<AMQP::Frame::Method:0x1010775e0
@channel=2,
@payload=
#<AMQP::Protocol::Basic::GetOk:0x1010774c8
@debug=1,
@delivery_tag=1,
@exchange="",
@message_count=91,
@redelivered=true,
@routing_key="async_code_execution">>]
["receive",
#<AMQP::Frame::Header:0x101066560
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x1010664e8
@klass=AMQP::Protocol::Basic,
@properties=
{:priority=>5,
:timestamp=>Mon Jul 18 12:58:14 -0500 2011,
:delivery_mode=>2,
:app_id=>"-29066@new-host-2",
:content_type=>"application/msgpack",
:expiration=>"28800",
:message_id=>"6ecab3a0-9395-012e-c483-34159e0c7034"},
@size=59,
@weight=0>>]
[:received,
#<AMQP::Frame::Header:0x101066560
@channel=2,
@payload=
#<AMQP::Protocol::Header:0x1010664e8
@klass=AMQP::Protocol::Basic,
@properties=
{:priority=>5,
:timestamp=>Mon Jul 18 12:58:14 -0500 2011,
:delivery_mode=>2,
:app_id=>"-29066@new-host-2",
:content_type=>"application/msgpack",
:expiration=>"28800",
:message_id=>"6ecab3a0-9395-012e-c483-34159e0c7034"},
@size=59,
@weight=0>>]
["receive",
#<AMQP::Frame::Body:0x10104a810
@channel=2,
@payload=
"\203\245clazz\260AutoRefreshCache\246method\262async_cache_update\246params\221\001">]
[:received,
#<AMQP::Frame::Body:0x10104a810
@channel=2,
@payload=
"\203\245clazz\260AutoRefreshCache\246method\262async_cache_update\246params\221\001">]
(async_code_execution)
Header:
:delivery_tag => 1
:message_count => 91
:priority => 5
:redelivered => true
:timestamp => Mon Jul 18 12:58:14 -0500 2011
:delivery_mode => 2
:app_id => "-29066@new-host-2"
:content_type => "application/msgpack"
:exchange => ""
:routing_key => "async_code_execution"
:expiration => "28800"
:message_id => "6ecab3a0-9395-012e-c483-34159e0c7034"
Message: {"clazz"=>"AutoRefreshCache", "method"=>"async_cache_update", "params"=>[1]}
[:sending,
#<AMQP::Protocol::Channel::Close:0x100563758
@class_id=0,
@debug=1,
@method_id=0,
@reply_code=200,
@reply_text="bye">]
["send",
#<AMQP::Frame::Method:0x100552890
@channel=1,
@payload=
#<AMQP::Protocol::Channel::Close:0x100563758
@class_id=0,
@debug=1,
@method_id=0,
@reply_code=200,
@reply_text="bye">>]
[:sending,
#<AMQP::Protocol::Channel::Close:0x100538b98
@class_id=0,
@debug=1,
@method_id=0,
@reply_code=200,
@reply_text="bye">]
["send",
#<AMQP::Frame::Method:0x10052a890
@channel=2,
@payload=
#<AMQP::Protocol::Channel::Close:0x100538b98
@class_id=0,
@debug=1,
@method_id=0,
@reply_code=200,
@reply_text="bye">>]
["receive",
#<AMQP::Frame::Method:0x1005158a0
@channel=1,
@payload=#<AMQP::Protocol::Channel::CloseOk:0x100515580 @debug=1>>]
[:received,
#<AMQP::Frame::Method:0x1005158a0
@channel=1,
@payload=#<AMQP::Protocol::Channel::CloseOk:0x100515580 @debug=1>>]
["receive",
#<AMQP::Frame::Method:0x1003be8f8
@channel=2,
@payload=#<AMQP::Protocol::Channel::CloseOk:0x1003be768 @debug=1>>]
[:received,
#<AMQP::Frame::Method:0x1003be8f8
@channel=2,
@payload=#<AMQP::Protocol::Channel::CloseOk:0x1003be768 @debug=1>>]
["send",
#<AMQP::Frame::Method:0x1003512a8
@channel=0,
@payload=
#<AMQP::Protocol::Connection::Close:0x1003516e0
@class_id=0,
@debug=1,
@method_id=0,
@reply_code=200,
@reply_text="Goodbye">>]
["receive",
#<AMQP::Frame::Method:0x100182da0
@channel=0,
@payload=#<AMQP::Protocol::Connection::CloseOk:0x100182be8 @debug=1>>]
["disconnected"]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment