Interface AutomaticIndexingQueueEventProcessingPlan
public interface AutomaticIndexingQueueEventProcessingPlan
-
Method Summary
Modifier and TypeMethodDescriptionvoidappend(String entityName, String serializedId, PojoIndexingQueueEventPayload payload) Appends an event to the plan, received from aAutomaticIndexingQueueEventSendingPlan.executeAndReport(OperationSubmitter operationSubmitter) Writes all pending changes to the index now, and clears the plan so that it can be re-used.toIdentifier(String entityName, String serializedId) Convert the serialized id to the original identifier.toSerializedId(String entityName, Object identifier) Convert the identifier to its serialized form.
-
Method Details
-
append
Appends an event to the plan, received from aAutomaticIndexingQueueEventSendingPlan.- Parameters:
entityName- The name of the entity type.serializedId- The serialized entity identifier.payload- The payload as passed to the sending plan.- See Also:
-
executeAndReport
CompletableFuture<MultiEntityOperationExecutionReport> executeAndReport(OperationSubmitter operationSubmitter) Writes all pending changes to the index now, and clears the plan so that it can be re-used.- Parameters:
operationSubmitter- How to handle request to submit operation when the queue is full.- Returns:
- A
CompletableFuturethat will be completed with an execution report when all the works are complete.
-
toSerializedId
Convert the identifier to its serialized form. The identifier type must be the one used by the entity having nameentityName.- Parameters:
entityName- The name of the entity.identifier- The provided identifier.- Returns:
- The serialized for of the provided identifier.
-
toIdentifier
-