Module: FakeSQS

Defined in:
lib/fake_sqs.rb,
lib/fake_sqs/api.rb,
lib/fake_sqs/queue.rb,
lib/fake_sqs/queues.rb,
lib/fake_sqs/server.rb,
lib/fake_sqs/message.rb,
lib/fake_sqs/version.rb,
lib/fake_sqs/responder.rb,
lib/fake_sqs/show_output.rb,
lib/fake_sqs/catch_errors.rb,
lib/fake_sqs/queue_factory.rb,
lib/fake_sqs/web_interface.rb,
lib/fake_sqs/error_response.rb,
lib/fake_sqs/actions/list_queues.rb,
lib/fake_sqs/actions/create_queue.rb,
lib/fake_sqs/actions/delete_queue.rb,
lib/fake_sqs/actions/send_message.rb,
lib/fake_sqs/actions/get_queue_url.rb,
lib/fake_sqs/actions/delete_message.rb,
lib/fake_sqs/actions/receive_message.rb,
lib/fake_sqs/actions/send_message_batch.rb,
lib/fake_sqs/actions/delete_message_batch.rb

Defined Under Namespace

Modules: Actions Classes: API, CatchErrors, ErrorResponse, Message, Queue, QueueFactory, Queues, Responder, Server, ShowOutput, WebInterface

Constant Summary collapse

InvalidAction =
Class.new(ArgumentError)
ReadCountOutOfRange =
Class.new(RuntimeError)
QueueNameExists =
Class.new(RuntimeError)
NonExistentQueue =
Class.new(RuntimeError)
VERSION =
"0.0.4"

Class Method Summary collapse

Class Method Details

.api(options = {}) ⇒ Object



19
20
21
22
23
24
25
# File 'lib/fake_sqs.rb', line 19

def self.api(options = {})
  API.new(
    server: options.fetch(:server),
    queues: queues,
    responder: responder
  )
end

.message_factoryObject



39
40
41
# File 'lib/fake_sqs.rb', line 39

def self.message_factory
  Message
end

.queueObject



43
44
45
# File 'lib/fake_sqs.rb', line 43

def self.queue
  Queue
end

.queue_factoryObject



35
36
37
# File 'lib/fake_sqs.rb', line 35

def self.queue_factory
  QueueFactory.new(message_factory: message_factory, queue: queue)
end

.queuesObject



27
28
29
# File 'lib/fake_sqs.rb', line 27

def self.queues
  Queues.new(queue_factory: queue_factory)
end

.responderObject



31
32
33
# File 'lib/fake_sqs.rb', line 31

def self.responder
  Responder.new
end

.server(options = {}) ⇒ Object



15
16
17
# File 'lib/fake_sqs.rb', line 15

def self.server(options = {})
  Server.new(options)
end