Interface ForwardTransaction<T extends PersistentData>
- Type Parameters:
T
- a subclass ofPersistentData
, the type of persistent data being forwarded
public interface ForwardTransaction<T extends PersistentData>
A transaction for forwarding persistent data to a sink / store.
-
Method Summary
-
Method Details
-
getData
-
onComplete
int onComplete()Called when the data has been successfully forwarded to the data sink / store.- Returns:
- number of data that was successfully forwarded
-
onFailure
Called when a failure occurs when forwarding to the data sink / store. After several failures, the data will likely be quarantined.- Returns:
- number of data that failed forwarding
-