Package com.attivio.util.ft
Interface TransactionReceiver
-
public interface TransactionReceiver
Basic interface to handle reading individual entries from a transaction log
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description boolean
add(long progress, byte[] id, IngestDocument doc)
Receive anIngestDocument
from the transaction logdefault boolean
add(long progress, PlatformMessage message)
Receive aPlatformMessage
from the transaction logboolean
delete(long progress, byte[] id)
Receive anIngestDocument
deletion from the transaction logboolean
delete(long progress, Query query)
Receive aQuery
-based deletion from the transaction log
-
-
-
Method Detail
-
add
boolean add(long progress, byte[] id, IngestDocument doc) throws java.io.IOException
Receive anIngestDocument
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 anIngestDocument
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 aQuery
-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 aPlatformMessage
from the transaction log- Returns:
- true if the transaction log recovery should continue - false if it should be canceled
- Throws:
java.io.IOException
-
-