Module: Consumer::Postgres

Included in:
Controls::Consumer::Example, Controls::Consumer::Identifier, Controls::Consumer::Incrementing
Defined in:
lib/consumer/postgres/postgres.rb,
lib/consumer/postgres/controls/id.rb,
lib/consumer/postgres/position_store.rb,
lib/consumer/postgres/controls/category.rb,
lib/consumer/postgres/controls/consumer.rb,
lib/consumer/postgres/controls/position.rb,
lib/consumer/postgres/controls/identifier.rb,
lib/consumer/postgres/controls/stream_name.rb,
lib/consumer/postgres/controls/message_data.rb,
lib/consumer/postgres/position_store/recorded.rb,
lib/consumer/postgres/position_store/stream_name.rb,
lib/consumer/postgres/controls/position/stream/write.rb,
lib/consumer/postgres/controls/position/store/recorded.rb

Defined Under Namespace

Modules: Controls Classes: PositionStore

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(cls) ⇒ Object 



3
4
5
6
7
 
# File 'lib/consumer/postgres/postgres.rb', line 3

def self.included(cls)
  cls.class_exec do
    include ::Consumer
  end
end

Instance Method Details

#configure(batch_size: nil, settings: nil, condition: nil) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/consumer/postgres/postgres.rb', line 9

def configure(batch_size: nil, settings: nil, condition: nil)
  MessageStore::Postgres::Session.configure(self, settings: settings)

  session = self.session
  PositionStore.configure(
    self,
    stream_name,
    consumer_identifier: identifier,
    session: session
  )

  get_session = MessageStore::Postgres::Session.build(settings: settings)
  MessageStore::Postgres::Get.configure(
    self,
    batch_size: batch_size,
    condition: condition,
    session: get_session
  )
end