lib/bbk/amqp/message.rb in bbk-amqp-1.0.0.72921 vs lib/bbk/amqp/message.rb in bbk-amqp-1.0.0.76397

@@ -31,9 +31,13 @@
 
       def reply_to
         headers[:reply_to]
       end
 
+      def user_id
+        headers[:user_id]
+      end
+
       def ack(*args, answer: nil, **kwargs)
         consumer.ack(self, *args, answer: answer, **kwargs)
       end
 
       def nack(*args, error: nil, **kwargs)