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