Class V3ReplicationProtocol

    • Constructor Detail

      • V3ReplicationProtocol

        public V3ReplicationProtocol​(QueryExecutor queryExecutor,
                                     PGStream pgStream)
    • Method Detail

      • startLogical

        public PGReplicationStream startLogical​(LogicalReplicationOptions options)
                                         throws java.sql.SQLException
        Specified by:
        startLogical in interface ReplicationProtocol
        Parameters:
        options - not null options for logical replication stream
        Returns:
        not null stream instance from which available fetch wal logs that was decode by output plugin
        Throws:
        java.sql.SQLException - on error