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, 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
 
# File 'lib/message_store/read.rb', line 3

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

    cls.extend Build
    cls.extend Call
    cls.extend Configure

    dependency :iterator, Iterator

    initializer :stream_name, :position, :batch_size

    abstract :configure
  end
end

Instance Method Details

#call(&action) ⇒ Object 



44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/message_store/read.rb', line 44

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

  if action.nil?
    error_message = "Reader must be actuated with a block"
    logger.error error_message
    raise Error, error_message
  end

  enumerate_message_data(&action)

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

  return AsyncInvocation::Incorrect
end

#enumerate_message_data(&action) ⇒ Object 



60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/message_store/read.rb', line 60

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

  message_data = nil

  loop do
    message_data = iterator.next

    break if message_data.nil?

    action.(message_data)
  end

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