lib/proletariat/subscriber.rb in proletariat-0.0.3 vs lib/proletariat/subscriber.rb in proletariat-0.0.4

@@ -115,10 +115,10 @@
     #           message bodies to listener#post.
     #
     # Returns nil.
     def start_consumer
       @consumer = bunny_queue.subscribe ack: true do |info, properties, body|
-        future = listener.post?(body)
+        future = listener.post?(body, info.routing_key)
         acknowledgers << Acknowledger.new(future, info.delivery_tag)
 
         nil
       end