class SXS::Publishers::Memory

Attributes

queue_url[R]

Public Class Methods

clear() click to toggle source
# File lib/sxs/publishers/memory.rb, line 25
def self.clear
  @queues = {}
end
new(queue_url) click to toggle source
# File lib/sxs/publishers/memory.rb, line 12
def initialize(queue_url)
  @queue_url = queue_url
end
queues() click to toggle source
# File lib/sxs/publishers/memory.rb, line 29
def self.queues
  @queues ||= {}
end

Public Instance Methods

messages() click to toggle source
# File lib/sxs/publishers/memory.rb, line 16
def messages
  self.class.queues[@queue_url]
end
publish(body) click to toggle source
# File lib/sxs/publishers/memory.rb, line 20
def publish(body)
  self.class.queues[@queue_url] ||= []
  self.class.queues[@queue_url] << body
end