lib/bbk/amqp/message.rb in bbk-amqp-1.1.0.199382 vs lib/bbk/amqp/message.rb in bbk-amqp-1.1.0.199449

@@ -47,9 +47,13 @@
 
       def clone
         self.class.new(consumer, delivery_info, properties, body)
       end
 
+      def protocol
+        consumer&.protocols&.first
+      end
+
     end
   end
 end