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