Class: Messaging::Adapters::Test::Store

Inherits:
Object
  • Object
show all
Defined in:
lib/messaging/adapters/test/store.rb

Overview

Message store adapter used for testing. It stores all messages in memory. Prefer accessing the message store through Messaging.message_store instead of using it directly.

Examples:

Using Test as the default message store adapter during tests:

# Put this in an initializer
Messaging.setup do |config|
  config.message_store.adapter = Rails.env.test? ? :test : :postgres
end

See Also:

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Store

Returns a new instance of Store.



32
33
34
 
# File 'lib/messaging/adapters/test/store.rb', line 32

def initialize
  clear!
end

Instance Attribute Details

#messages ⇒ Array<Messaging::Message> (readonly)

Access to all messages.

Examples:

Check that a message has been added to the store with Rspec

expect do
  # Your code that should add a message to the store
end.to change { Messaging.message_store.messages.count }.from(0).to(1)

Returns:



27
28
29
 
# File 'lib/messaging/adapters/test/store.rb', line 27

def messages
  @messages
end

#streams ⇒ Streams (readonly)

Returns all the streams in the store.

Returns:

  • (Streams) —

    all the streams in the store

See Also:



30
31
32
 
# File 'lib/messaging/adapters/test/store.rb', line 30

def streams
  @streams
end

Instance Method Details

#call(message) ⇒ Messaging::Message

Writes the message to the store Skips messages that hasn’t defined a stream name

Parameters:

Returns:

  • (Messaging::Message) —

    A new copy of the message with the stream position added (if persisted)



54
55
56
57
58
59
60
61
62
63
 
# File 'lib/messaging/adapters/test/store.rb', line 54

def call(message)
  return message unless message.stream_name

  stream = stream(message.stream_name)
  ExpectedVersion.new(message.expected_version || :any).match!(stream.current_position)
  persisted_message = message.class.new(message.attributes.merge(stream_position: stream.current_position + 1))
  @messages << persisted_message
  stream.messages << persisted_message
  persisted_message
end

#clear! ⇒ Object 



43
44
45
46
 
# File 'lib/messaging/adapters/test/store.rb', line 43

def clear!
  @streams = Hash.new { |h, k| h[k] = Stream.new(k) }
  @messages = []
end

#stream(name) ⇒ Stream

Get a specific stream by name

Returns:

See Also:

  • Messaging.strea


39
40
41
 
# File 'lib/messaging/adapters/test/store.rb', line 39

def stream(name)
  streams[name]
end