Interface AutomaticIndexingQueueEventProcessingPlan
-
public interface AutomaticIndexingQueueEventProcessingPlan
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidappend(String entityName, String serializedId, PojoIndexingQueueEventPayload payload)Appends an event to the plan, received from aAutomaticIndexingQueueEventSendingPlan.CompletableFuture<MultiEntityOperationExecutionReport<EntityReference>>executeAndReport()Writes all pending changes to the index now, and clears the plan so that it can be re-used.ObjecttoIdentifier(String entityName, String serializedId)Convert the serialized id to the original identifier.StringtoSerializedId(String entityName, Object identifier)Convert the identifier to its serialized form.
-
-
-
Method Detail
-
append
void append(String entityName, String serializedId, PojoIndexingQueueEventPayload payload)
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:
AutomaticIndexingQueueEventSendingPlan.append(String, Object, String, PojoIndexingQueueEventPayload)
-
executeAndReport
CompletableFuture<MultiEntityOperationExecutionReport<EntityReference>> executeAndReport()
Writes all pending changes to the index now, and clears the plan so that it can be re-used.- Returns:
- A
CompletableFuturethat will be completed with an execution report when all the works are complete.
-
toSerializedId
String toSerializedId(String entityName, Object identifier)
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.
-
-