LogicalReplication { public Connection createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig) throws SQLException { return createConnection(jdbcDataSourceConfig); }  Connection createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig); PGReplicationStream createReplicationStream(final Connection pgConnection, final String slotName, final LogSequenceNumber startPosition);  }
@Test public void assertCreatePgConnectionSuccess() throws SQLException { Connection pgConnection = logicalReplication.createPgConnection( new JDBCScalingDataSourceConfiguration("jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=PostgreSQL", "root", "root")); assertFalse(pgConnection.isClosed()); }