Created
July 19, 2011 16:51
-
-
Save maheshmurthy/1093039 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ["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