lib/freddy/message_handler.rb in freddy-jruby-0.5.1 vs lib/freddy/message_handler.rb in freddy-jruby-0.5.6

@@ -1,19 +1,16 @@
 class Freddy
   class MessageHandler
-    attr_reader :correlation_id
-
     def initialize(adapter, delivery)
       @adapter = adapter
       @delivery = delivery
-      @correlation_id = @delivery.correlation_id
     end
 
     def success(response = nil)
-      @adapter.success(@delivery.reply_to, response)
+      @adapter.success(@delivery, response)
     end
 
-    def error(error = {error: "Couldn't process message"})
-      @adapter.error(@delivery.reply_to, error)
+    def error(response = {error: "Couldn't process message"})
+      @adapter.error(@delivery, response)
     end
   end
 end