Sha256: a49ca76f9f71bcd21821ef20cad16fe7909edb33e24fd895337bd4299ef51c86
Contents?: true
Size: 505 Bytes
Versions: 4
Compression:
Stored size: 505 Bytes
Contents
# module OmfCommon # class TopicMessage # attr_accessor :body, :comm # # def initialize(body, comm) # self.body ||= body # self.comm ||= comm # end # # def publish(topic_id, &block) # comm.publish(topic_id, body.dup, &block) # end # # %w(created status failed released).each do |itype| # define_method("on_inform_#{itype}") do |*args, &message_block| # comm.send("on_#{itype}_message", body, &message_block) # end # end # end # end
Version data entries
4 entries across 4 versions & 1 rubygems