class RackRabbit::Adapter::Mock
Attributes
connection[RW]
Public Instance Methods
ack(delivery_tag)
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 48 def ack(delivery_tag) acked_messages << delivery_tag end
acked_messages()
click to toggle source
connect()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 19 def connect @connected = true end
connected?()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 27 def connected? !!@connected end
disconnect()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 23 def disconnect @connected = false end
prime(message)
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 80 def prime(message) queue << message end
publish(body, properties)
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 40 def publish(body, properties) published_messages << properties.merge(:body => body) end
published_messages()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 68 def published_messages @published_messages ||= [] end
queue()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 76 def queue @queue ||= [] end
reject(delivery_tag)
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 52 def reject(delivery_tag) rejected_messages << delivery_tag end
rejected_messages()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 64 def rejected_messages @rejected_messages ||= [] end
shutdown()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 11 def shutdown @started = false end
started?()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 15 def started? !!@started end
startup()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 7 def startup @started = true end
subscribe(options = {}) { |message| ... }
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 31 def subscribe(options = {}, &block) @subscribe_options = options while !queue.empty? message = queue.shift yield message subscribed_messages << message end end
subscribe_options()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 84 def subscribe_options @subscribe_options end
subscribed_messages()
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 72 def subscribed_messages @subscribed_messages ||= [] end
with_reply_queue() { |mock_reply_queue :name => "queue"| ... }
click to toggle source
# File lib/rack-rabbit/adapter/mock.rb, line 44 def with_reply_queue(&block) yield MockReplyQueue.new :name => "reply.queue" end