Class: SXS::Publishers::Memory

Inherits:

Object

• Object
• SXS::Publishers::Memory

Extended by:

Forwardable

Defined in:

lib/sxs/publishers/memory.rb

Instance Attribute Summary

• #queue_url ⇒ Object readonly

  Returns the value of attribute queue_url.

Class Method Summary

• .clear ⇒ Object
• .queues ⇒ Object

Instance Method Summary

• #initialize(queue_url) ⇒ Memory constructor

  A new instance of Memory.

• #messages ⇒ Object
• #publish(body) ⇒ Object

Constructor Details

#initialize(queue_url) ⇒ Memory

# File 'lib/sxs/publishers/memory.rb', line 12

def initialize(queue_url)
  @queue_url = queue_url
end

Instance Attribute Details

#queue_url ⇒ Object (readonly)

Returns the value of attribute queue_url.

# File 'lib/sxs/publishers/memory.rb', line 8

def queue_url
  @queue_url
end

Class Method Details

.clear ⇒ Object

# File 'lib/sxs/publishers/memory.rb', line 25

def self.clear
  @queues = {}
end

.queues ⇒ Object

# File 'lib/sxs/publishers/memory.rb', line 29

def self.queues
  @queues ||= {}
end

Instance Method Details

#messages ⇒ Object

# File 'lib/sxs/publishers/memory.rb', line 16

def messages
  self.class.queues[@queue_url]
end

#publish(body) ⇒ Object

# File 'lib/sxs/publishers/memory.rb', line 20

def publish(body)
  self.class.queues[@queue_url] ||= []
  self.class.queues[@queue_url] << body
end