Use version amqp 0.9 for publishing
MODIFY
lib/beetle/publisher.rb
lib/beetle/publisher.rb
@@ -166,7 +166,8 @@ module Beetle
:pass => @client.config.password,
:vhost => @client.config.vhost,
:frame_max => @client.config.frame_max,
- :socket_timeout => @client.config.publishing_timeout)
+ :socket_timeout => @client.config.publishing_timeout,
+ :spec => '09')
b.start
b
end

MODIFY
test/beetle/publisher_test.rb
test/beetle/publisher_test.rb
@@ -24,7 +24,8 @@ module Beetle
:pass => "guest",
:vhost => "/",
:socket_timeout => 0,
- :frame_max => 131072
+ :frame_max => 131072,
+ :spec => '09'
}
Bunny.expects(:new).with(expected_bunny_options).returns(m)
m.expects(:start)

Use version amqp 0.9 for publishing