Subscription uses the same session as the handlers

Author: ntl

lib/consumer/postgres/postgres.rb

@@ -59,8 +59,6 @@ def configure(session_settings: nil, batch_size: nil, correlation: nil, group_me
  MessageStore::Postgres::Session.configure(self, settings: session_settings)
  session = self.session
 
- get_session = MessageStore::Postgres::Session.build(settings: settings)
-
  MessageStore::Postgres::Get::Category.configure(
  self,
  category,
@@ -69,7 +67,7 @@ def configure(session_settings: nil, batch_size: nil, correlation: nil, group_me
  consumer_group_member: group_member,
  consumer_group_size: group_size,
  condition: condition,
- session: get_session
+ session: session
  )
 
  PositionStore.configure(

test/automated/build/build.rb

@@ -64,10 +64,6 @@
  test "Is set" do
  assert(get.session.instance_of?(consumer.session.class))
  end
-
- test "Assigned a different session from consumer" do
- refute(get.session.equal?(consumer.session))
- end
  end
  end