Type Parameters:
T - a subclass of PersistentData, 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

    Modifier and Type
    Method
    Description
     
    int
    Called when the data has been successfully forwarded to the data sink / store.
    int
    Called when a failure occurs when forwarding to the data sink / store.
  • Method Details

    • getData

      List<T> 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

      int onFailure(Exception err)
      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