lib/asir/transport/delegation.rb in asir-0.2.0 vs lib/asir/transport/delegation.rb in asir-1.0.1

@@ -22,20 +22,20 @@
       # Return the subTransports#send_message result unmodified from #_send_message.
       def receive_result message, opaque_result
         opaque_result
       end
 
-      def needs_message_identifier?
+      def needs_message_identifier? message
         @needs_message_identifier ||
-          transports.any? { | t | t.needs_message_identifier? }
+          transports.any? { | t | t.needs_message_identifier?(message) }
       end
 
-      def needs_message_timestamp?
+      def needs_message_timestamp? message
         @needs_message_timestamp ||
-          transports.any? { | t | t.needs_message_timestamp? }
+          transports.any? { | t | t.needs_message_timestamp?(message) }
       end
 
-      # Subclasses with multiple transport should override this method.
+      # Subclasses with multiple transports should override this method.
       def transports
         @transports ||= [ transport ]
       end
 
       # Called from within _send_message rescue.