Package io.serverlessworkflow.impl.persistence

Interface CorrelationOperations

All Known Subinterfaces:
PersistenceInstanceOperations, PersistenceInstanceTransaction
public interface CorrelationOperations

  • Method Details

    • retrieveEvents

      default void retrieveEvents(Map<String,Collection<io.cloudevents.CloudEvent>> reg2EventsMap)

    • storeEvent

      default void storeEvent(String regId, io.cloudevents.CloudEvent event)

    • markAsProcessed

      default void markAsProcessed(Map<String,Collection<String>> regCeIds)

    • clearProcessed

      default void clearProcessed()

    • removeCloudEvents

      default void removeCloudEvents(Map<String,String> ids)