public interface Crystalizer
State for a given process ID is purged when a final completion event is received so there is no need for an explicit cache purge operation in the public API (although for termination of partially complete workflows it may be sensible for subclasses to provide one)
Modifier and Type | Method and Description |
---|---|
void |
completionCreated(Completion completion)
Called whenever a completion not corresponding to a node in the cache is
generated.
|
void |
jobCreated(Job outputJob)
This method is called when a new Job has been handled by the
AbstractCrystalizer, either by direct passthrough or by list
registration.
|
void |
receiveEvent(IterationInternalEvent<? extends IterationInternalEvent<?>> event)
Receive a Job or Completion, Jobs are emitted unaltered and cached,
Completion events trigger registration of a corresponding list - this may
be recursive in nature if the completion event's index implies nested
lists which have not been registered.
|
void receiveEvent(IterationInternalEvent<? extends IterationInternalEvent<?>> event)
void jobCreated(Job outputJob)
void completionCreated(Completion completion)
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.