Interface ChainedLogicalStreamBuilder
-
- All Superinterfaces:
ChainedCommonStreamBuilder<ChainedLogicalStreamBuilder>
- All Known Implementing Classes:
LogicalStreamBuilder
public interface ChainedLogicalStreamBuilder extends ChainedCommonStreamBuilder<ChainedLogicalStreamBuilder>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PGReplicationStream
start()
Open logical replication stream.ChainedLogicalStreamBuilder
withSlotOption(java.lang.String optionName, boolean optionValue)
ChainedLogicalStreamBuilder
withSlotOption(java.lang.String optionName, int optionValue)
ChainedLogicalStreamBuilder
withSlotOption(java.lang.String optionName, java.lang.String optionValue)
ChainedLogicalStreamBuilder
withSlotOptions(java.util.Properties options)
-
Methods inherited from interface org.postgresql.replication.fluent.ChainedCommonStreamBuilder
withSlotName, withStartPosition, withStatusInterval
-
-
-
-
Method Detail
-
start
PGReplicationStream start() throws java.sql.SQLException
Open logical replication stream.- Returns:
- not null PGReplicationStream available for fetch data in logical form
- Throws:
java.sql.SQLException
- if there are errors
-
withSlotOption
ChainedLogicalStreamBuilder withSlotOption(java.lang.String optionName, boolean optionValue)
- Parameters:
optionName
- name of optionoptionValue
- boolean value- Returns:
- ChainedLogicalStreamBuilder
-
withSlotOption
ChainedLogicalStreamBuilder withSlotOption(java.lang.String optionName, int optionValue)
- Parameters:
optionName
- name of optionoptionValue
- integer value- Returns:
- ChainedLogicalStreamBuilder
-
withSlotOption
ChainedLogicalStreamBuilder withSlotOption(java.lang.String optionName, java.lang.String optionValue)
- Parameters:
optionName
- name of optionoptionValue
- String value- Returns:
- ChainedLogicalStreamBuilder
-
withSlotOptions
ChainedLogicalStreamBuilder withSlotOptions(java.util.Properties options)
- Parameters:
options
- properties- Returns:
- ChainedLogicalStreamBuilder
-
-