Condition can be specified for consumers

Author: ntl

lib/consumer/postgres/postgres.rb

@@ -6,11 +6,12 @@ def self.included(cls)
  end
  end
 
- def configure(session: nil, batch_size: nil, position_store: nil)
+ def configure(session: nil, batch_size: nil, position_store: nil, condition: nil)
  MessageStore::Postgres::Get.configure(
  self,
- session: session,
- batch_size: batch_size
+ batch_size: batch_size,
+ condition: condition,
+ session: session
  )
 
  PositionStore.configure(

test/automated/condition.rb

@@ -0,0 +1,19 @@
+require_relative './automated_init'
+
+context "Condition" do
+ stream_name = Controls::StreamName.example
+
+ condition = 'position = 0'
+
+ consumer = Controls::Consumer::Example.build(stream_name, condition: condition)
+
+ context "Get Dependency" do
+ get = consumer.get
+
+ get_condition = get.condition
+
+ test "Condition is configured" do
+ assert(get_condition == condition)
+ end
+ end
+end

test/interactive/start_consumer.rb

@@ -10,9 +10,12 @@
  end
 end
 
+condition = ENV['CONDITION']
+
 Actor::Supervisor.start do
  Controls::Consumer::Incrementing.start(
  category,
+ condition: condition,
  position_update_interval: position_update_interval
  )
 end