lib/legion/transport/message.rb in legion-transport-1.1.6 vs lib/legion/transport/message.rb in legion-transport-1.1.8

@@ -105,9 +105,13 @@
       end
 
       def validate
         @valid = true
       end
+
+      def channel
+        Legion::Transport::Connection.channel
+      end
     end
   end
 end
 
 Dir["#{__dir__}/messages/*.rb"].sort.each { |file| require file }