Channel#frame_size currently returns Session#frame_max, so remove thi…

…s condition
ruby-amqp · Nov 30, 2012 · fb02d4b · fb02d4b
1 parent 4186ba3
commit fb02d4b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/bunny/channel.rb b/lib/bunny/channel.rb
@@ -165,7 +165,7 @@ def basic_publish(payload, exchange, routing_key, opts = {})
 
       meta = { :priority => 0, :delivery_mode => 2, :content_type => "application/octet-stream" }.
         merge(opts)
-      @connection.send_frameset(AMQ::Protocol::Basic::Publish.encode(@id, payload, meta, exchange_name, routing_key, meta[:mandatory], false, (frame_size || @connection.frame_max)), self)
+      @connection.send_frameset(AMQ::Protocol::Basic::Publish.encode(@id, payload, meta, exchange_name, routing_key, meta[:mandatory], false, @connection.frame_max), self)
 
       self
     end