Module: MessageStore::Read

Included in:
Controls::Read::Example
Defined in:
lib/message_store/read.rb,
lib/message_store/read/iterator.rb

Defined Under Namespace

Modules: Build, Call, Configure Classes: Iterator

Constant Summary collapse

Error = 
Class.new(RuntimeError)

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(cls) ⇒ Object 



3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/message_store/read.rb', line 3

def self.included(cls)
  cls.class_exec do
    include Dependency
    include Initializer
    include TemplateMethod
    include Log::Dependency

    extend Build
    extend Call
    extend Configure

    dependency :iterator, Iterator

    initializer :stream_name, :position, :batch_size

    template_method! :configure
  end
end

Instance Method Details

#call(&action) ⇒ Object 



48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
# File 'lib/message_store/read.rb', line 48

def call(&action)
  logger.trace(tag: :read) { "Reading (Stream Name: #{stream_name})" }

  if action.nil?
    error_message = "Reader must be actuated with a block"
    logger.error(tag: :read) { error_message }
    raise Error, error_message
  end

  enumerate_message_data(&action)

  logger.info(tag: :read) { "Reading completed (Stream Name: #{stream_name})" }

  return AsyncInvocation::Incorrect
end

#enumerate_message_data(&action) ⇒ Object 



64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/message_store/read.rb', line 64

def enumerate_message_data(&action)
  logger.trace(tag: :read) { "Enumerating (Stream Name: #{stream_name})" }

  message_data = nil

  loop do
    message_data = iterator.next

    break if message_data.nil?
    logger.debug(tags: [:data, :message_data]) { message_data.pretty_inspect }

    action.(message_data)
  end

  logger.debug(tag: :read) { "Enumerated (Stream Name: #{stream_name})" }
end