Top Fields Constructors Methods
org.postgresql.replication.fluent

public Class ReplicationCreateSlotBuilder

extends Object
implements ChainedCreateReplicationSlotBuilder
Class Inheritance
All Implemented Interfaces
org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder
Imports
org.postgresql.core.BaseConnection, org.postgresql.replication.fluent.logical.ChainedLogicalCreateSlotBuilder, .LogicalCreateSlotBuilder, org.postgresql.replication.fluent.physical.ChainedPhysicalCreateSlotBuilder, .PhysicalCreateSlotBuilder

Field Summary

Modifier and TypeField and Description
private final BaseConnection
baseConnection

Constructor Summary

AccessConstructor and Description
public
ReplicationCreateSlotBuilder(BaseConnection baseConnection)

Method Summary

Modifier and TypeMethod and Description
public ChainedLogicalCreateSlotBuilder
logical()

Implements org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder.logical.

Get the logical slot builder.

public ChainedPhysicalCreateSlotBuilder
physical()

Implements org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder.physical.

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

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

baseConnectionback to summary
private final BaseConnection baseConnection

Constructor Detail

ReplicationCreateSlotBuilderback to summary
public ReplicationCreateSlotBuilder(BaseConnection baseConnection)

Method Detail

logicalback to summary
public ChainedLogicalCreateSlotBuilder logical()

Implements org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder.logical.

Doc from org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder.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:ChainedLogicalCreateSlotBuilder

not null fluent api

Annotations
@Override
physicalback to summary
public ChainedPhysicalCreateSlotBuilder physical()

Implements org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder.physical.

Doc from org.postgresql.replication.fluent.ChainedCreateReplicationSlotBuilder.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:ChainedPhysicalCreateSlotBuilder

not null fluent api

Annotations
@Override