Interface ChainedLogicalStreamBuilder

    • 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 option
        optionValue - boolean value
        Returns:
        ChainedLogicalStreamBuilder
      • withSlotOption

        ChainedLogicalStreamBuilder withSlotOption​(java.lang.String optionName,
                                                   int optionValue)
        Parameters:
        optionName - name of option
        optionValue - integer value
        Returns:
        ChainedLogicalStreamBuilder
      • withSlotOption

        ChainedLogicalStreamBuilder withSlotOption​(java.lang.String optionName,
                                                   java.lang.String optionValue)
        Parameters:
        optionName - name of option
        optionValue - String value
        Returns:
        ChainedLogicalStreamBuilder
      • withSlotOptions

        ChainedLogicalStreamBuilder withSlotOptions​(java.util.Properties options)
        Parameters:
        options - properties
        Returns:
        ChainedLogicalStreamBuilder