diff --git a/spec/event_sourcery/event_store/subscription_spec.rb b/spec/event_sourcery/event_store/subscription_spec.rb
index <HASH>..<HASH> 100644
--- a/spec/event_sourcery/event_store/subscription_spec.rb
+++ b/spec/event_sourcery/event_store/subscription_spec.rb
@@ -20,7 +20,7 @@ RSpec.describe EventSourcery::EventStore::Subscription do
   end
 
   let(:event_types) { nil }
-  let(:event_store) { EventSourcery::EventStore::Postgres::Connection.new(pg_connection) }
+  let(:event_store) { EventSourcery::EventStore::Postgres::ConnectionWithOptimisticConcurrency.new(pg_connection) }
   subject(:subscription) { described_class.new(event_store: event_store,
                                                poll_waiter: waiter,
                                                event_types: event_types,
Use optimistic concurrency connection in subscription spec