Interface ChainedCreateReplicationSlotBuilder

All Known Implementing Classes:
ReplicationCreateSlotBuilder
public interface ChainedCreateReplicationSlotBuilder
Fluent interface for specify common parameters for Logical and Physical replication.

  • Method Details

    • logical

      ChainedLogicalCreateSlotBuilder logical()
      Get the logical slot builder. Example usage: 
        

   pgConnection
       .getReplicationAPI()
       .createReplicationSlot()
       .logical()
       .withSlotName("mySlot")
       .withOutputPlugin("test_decoding")
       .make();

   PGReplicationStream stream =
       pgConnection
           .getReplicationAPI()
           .replicationStream()
           .logical()
           .withSlotName("mySlot")
           .withSlotOption("include-xids", false)
           .withSlotOption("skip-empty-xacts", true)
           .start();

   while (true) {
     ByteBuffer buffer = stream.read();
     //process logical changes
   }
      Returns:
      not null fluent api

    • physical

      ChainedPhysicalCreateSlotBuilder physical()
      Create physical replication stream for process wal logs in binary form.

      Example usage:

        

   pgConnection
       .getReplicationAPI()
       .createReplicationSlot()
       .physical()
       .withSlotName("mySlot")
       .make();

   PGReplicationStream stream =
       pgConnection
           .getReplicationAPI()
           .replicationStream()
           .physical()
           .withSlotName("mySlot")
           .start();

   while (true) {
     ByteBuffer buffer = stream.read();
     //process binary WAL logs
   }
      Returns:
      not null fluent api