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