Module: Consumer::EventStore
- Included in:
- Controls::Consumer::Example, Controls::Consumer::Identifier, Controls::Consumer::Incrementing
- Defined in:
- lib/consumer/event_store/event_store.rb,
lib/consumer/event_store/copy_session.rb,
lib/consumer/event_store/position_store.rb,
lib/consumer/event_store/controls/handle.rb,
lib/consumer/event_store/controls/category.rb,
lib/consumer/event_store/controls/consumer.rb,
lib/consumer/event_store/controls/identifier.rb,
lib/consumer/event_store/controls/stream_name.rb,
lib/consumer/event_store/controls/message_data.rb,
lib/consumer/event_store/position_store/updated.rb,
lib/consumer/event_store/controls/position_stream.rb,
lib/consumer/event_store/position_store/stream_name.rb
Defined Under Namespace
Modules: Controls, CopySession
Classes: PositionStore
Class Method Summary
collapse
Instance Method Summary
collapse
Class Method Details
.included(cls) ⇒ Object
3
4
5
6
7
|
# File 'lib/consumer/event_store/event_store.rb', line 3
def self.included(cls)
cls.class_exec do
include Consumer
end
end
|
Instance Method Details
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
# File 'lib/consumer/event_store/event_store.rb', line 9
def configure(session: nil, batch_size: nil, position_store: nil)
cycle_timeout = cycle_timeout_milliseconds || Consumer::Subscription::Defaults.cycle_timeout_milliseconds
long_poll_duration = Rational(cycle_timeout, 1000).ceil
unless session.nil?
get_session = CopySession.(session)
end
MessageStore::EventStore::Get.configure(
self,
batch_size: batch_size,
long_poll_duration: long_poll_duration,
session: get_session
)
PositionStore.configure(
self,
stream_name,
position_store: position_store,
consumer_identifier: identifier,
session: session
)
end
|