class CrystalMQ::Consumer::ConsumerPayload
Attributes
channel[R]
topic[R]
Public Class Methods
from_msgpack(h)
click to toggle source
# File lib/crystalmq.rb, line 34 def self.from_msgpack h @topic = h["topic"] @channel = h["channel"] end
new(topic, channel)
click to toggle source
# File lib/crystalmq.rb, line 25 def initialize(topic, channel) @topic = topic @channel = channel end
Public Instance Methods
to_msgpack()
click to toggle source
# File lib/crystalmq.rb, line 30 def to_msgpack { "topic" => @topic, "channel" => @channel }.to_msgpack end