Interface TransactionReceiver


  • public interface TransactionReceiver
    Basic interface to handle reading individual entries from a transaction log
    • Method Detail

      • add

        boolean add​(long progress,
                    byte[] id,
                    IngestDocument doc)
             throws java.io.IOException
        Receive an IngestDocument from the transaction log
        Returns:
        true if the transaction log recovery should continue - false if it should be canceled
        Throws:
        java.io.IOException
      • delete

        boolean delete​(long progress,
                       byte[] id)
                throws java.io.IOException
        Receive an IngestDocument deletion from the transaction log
        Returns:
        true if the transaction log recovery should continue - false if it should be canceled
        Throws:
        java.io.IOException
      • delete

        boolean delete​(long progress,
                       Query query)
                throws java.io.IOException
        Receive a Query-based deletion from the transaction log
        Returns:
        true if the transaction log recovery should continue - false if it should be canceled
        Throws:
        java.io.IOException
      • add

        default boolean add​(long progress,
                            PlatformMessage message)
                     throws java.io.IOException
        Receive a PlatformMessage from the transaction log
        Returns:
        true if the transaction log recovery should continue - false if it should be canceled
        Throws:
        java.io.IOException