lib/message_driver/destination.rb in message-driver-0.2.2 vs lib/message_driver/destination.rb in message-driver-0.3.0

@@ -9,14 +9,14 @@
         @dest_options = dest_options
         @message_props = message_props
       end
 
       def publish(body, headers={}, properties={})
-        Client.publish(self, body, headers, properties)
+        adapter.broker.client.publish(self, body, headers, properties)
       end
 
       def pop_message(options={})
-        Client.pop_message(self, options)
+        adapter.broker.client.pop_message(self, options)
       end
 
       def after_initialize(adapter_context)
         #does nothing, feel free to override as needed
       end