Interface OutboxPollingSearchMapping
-
@Incubating public interface OutboxPollingSearchMapping
Exposes some utilities to handle aborted events, which are events that have been processed many times without success.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
clearAllAbortedEvents()
Delete all events that are at the moment in aborted state.int
clearAllAbortedEvents(String tenantId)
Delete all events that are at the moment in aborted state.long
countAbortedEvents()
Returns the number of events that are at the moment in aborted state.long
countAbortedEvents(String tenantId)
Returns the number of events that are at the moment in aborted state.int
reprocessAbortedEvents()
Reprocess events that are at the moment in aborted state.int
reprocessAbortedEvents(String tenantId)
Reprocess events that are at the moment in aborted state.
-
-
-
Method Detail
-
countAbortedEvents
long countAbortedEvents()
Returns the number of events that are at the moment in aborted state.This method only works for single-tenant applications. If multi-tenancy is enabled, use
countAbortedEvents(String)
instead.- Returns:
- The number of aborted events
-
countAbortedEvents
long countAbortedEvents(String tenantId)
Returns the number of events that are at the moment in aborted state.This method only works for multi-tenant applications. If multi-tenancy is disabled, use
countAbortedEvents()
instead.- Parameters:
tenantId
- The identifier of the tenant whose index content should be targeted- Returns:
- The number of aborted events
-
reprocessAbortedEvents
int reprocessAbortedEvents()
Reprocess events that are at the moment in aborted state.This method only works for single-tenant applications. If multi-tenancy is enabled, use
reprocessAbortedEvents(String)
instead.- Returns:
- The number of reprocessed events
-
reprocessAbortedEvents
int reprocessAbortedEvents(String tenantId)
Reprocess events that are at the moment in aborted state.This method only works for multi-tenant applications. If multi-tenancy is disabled, use
reprocessAbortedEvents()
instead.- Parameters:
tenantId
- The identifier of the tenant whose index content should be targeted- Returns:
- The number of reprocessed events
-
clearAllAbortedEvents
int clearAllAbortedEvents()
Delete all events that are at the moment in aborted state.This method only works for single-tenant applications. If multi-tenancy is enabled, use
clearAllAbortedEvents(String)
instead.- Returns:
- The number of deleted events
-
clearAllAbortedEvents
int clearAllAbortedEvents(String tenantId)
Delete all events that are at the moment in aborted state.This method only works for multi-tenant applications. If multi-tenancy is disabled, use
clearAllAbortedEvents()
instead.- Parameters:
tenantId
- The identifier of the tenant whose index content should be targeted- Returns:
- The number of deleted events
-
-