lib/amqp/client.rb in amqp-client-0.2.0 vs lib/amqp/client.rb in amqp-client-0.2.1

@@ -121,11 +121,11 @@
       def publish(body, **properties)
         @client.publish(body, "", @name, **properties)
         self
       end
 
-      def subscribe(prefetch: 1, arguments: {}, &blk)
-        @client.subscribe(@name, prefetch: prefetch, arguments: arguments, &blk)
+      def subscribe(no_ack: false, prefetch: 1, worker_threads: 1, arguments: {}, &blk)
+        @client.subscribe(@name, no_ack: no_ack, prefetch: prefetch, worker_threads: worker_threads, arguments: arguments, &blk)
         self
       end
 
       def bind(exchange, routing_key, **headers)
         @client.bind(@name, exchange, routing_key, **headers)