class Smith::Messaging::Sender
Attributes
queue_name[R]
Public Class Methods
new(queue_name, _opts = nil, &blk)
click to toggle source
# File lib/fake_smith.rb, line 158 def initialize(queue_name, _opts = nil, &blk) @queue_name = queue_name blk.call(self) if block_given? end
Public Instance Methods
message_count(&blk)
click to toggle source
# File lib/fake_smith.rb, line 178 def message_count(&blk) blk.call FakeSmith.get_messages(@queue_name).count if block_given? end
on_reply(_opts, &blk)
click to toggle source
# File lib/fake_smith.rb, line 163 def on_reply(_opts, &blk) @on_reply = blk end
on_timeout(&blk)
click to toggle source
# File lib/fake_smith.rb, line 167 def on_timeout(&blk) end
publish(message, opts={}, &blk)
click to toggle source
# File lib/fake_smith.rb, line 170 def publish(message, opts={}, &blk) FakeSmith.add_message(@queue_name, message) blk.call if block_given? if FakeSmith.reply_handlers[@queue_name] && @on_reply @on_reply.call(FakeSmith.reply_handlers[@queue_name].call(message)) end end