lib/amqp/queue.rb in amqp-0.8.0.rc8 vs lib/amqp/queue.rb in amqp-0.8.0.rc9

@@ -640,10 +640,10 @@
     #
     # @note This method will be removed before 1.0 release
     # @deprecated
     # @api public
     def publish(data, opts = {})
-      exchange.publish(data, opts)
+      exchange.publish(data, opts.merge(:routing_key => self.name))
     end
 
     # Resets queue state. Useful for error handling.
     # @api plugin
     def reset