lib/plumbing/actor/threaded.rb in standard-procedure-plumbing-0.4.1 vs lib/plumbing/actor/threaded.rb in standard-procedure-plumbing-0.4.2

@@ -14,11 +14,11 @@
         @queue = Concurrent::Array.new
         @mutex = Thread::Mutex.new
       end
 
       # Send the message to the target and wrap the result
-      def send_message message_name, *args, &block
-        Message.new(@target, message_name, Plumbing::Actor.transporter.marshal(*args), block, Concurrent::MVar.new).tap do |message|
+      def send_message(message_name, *args, **params, &block)
+        Message.new(@target, message_name, Plumbing::Actor.transporter.marshal(*args, **params), block, Concurrent::MVar.new).tap do |message|
           @mutex.synchronize do
             @queue << message
             send_messages if @queue.any?
           end
         end