Class: AggregateStreams::Consumer

Inherits:
Object
  • Object
show all
Includes:
Consumer::Postgres
Defined in:
lib/aggregate_streams/consumer.rb

Instance Method Summary collapse

Instance Method Details

#configure(output_category:, output_session: nil, **args) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/aggregate_streams/consumer.rb', line 7

def configure(output_category:, output_session: nil, **args)
  super(**args)

  input_category = self.category

  PositionStore.configure(
    self,
    input_category,
    output_category,
    session: output_session
  )
end