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
TEST HELPER METHODS
# File lib/rack-rabbit/adapter/mock.rb, line 60
def acked_messages
  @acked_messages ||= []
end
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