process(
processor: ControllerEventProcessor): UnitQueuedEvent — ControllerEvent with Enqueue Time
QueuedEvent is a ControllerEvent with the time it was enqueued (enqueue time) to ControllerEventManager.
QueuedEvent is created every time ControllerEventManager is requested to enqueue a controller event.
Processing ControllerEvent Using ControllerEventProcessor — process Method
process atomically turns the spent internal registry on and simply exits when it was on already.
process decrements the count of the processingStarted internal latch.
In the end, process simply requests the given ControllerEventProcessor to process the controller event.
|
Note
|
process is used exclusively when ControllerEventThread is requested to process controller events.
|
Preempting ControllerEvent Using ControllerEventProcessor — preempt Method
preempt(
processor: ControllerEventProcessor): Unitpreempt atomically turns the spent internal registry on and simply exits when it was on already.
In the end, preempt simply requests the given ControllerEventProcessor to preempt the controller event.
|
Note
|
preempt is used exclusively when ControllerEventManager is requested to clearAndPut.
|
awaitProcessing Method
awaitProcessing(): UnitawaitProcessing simply pauses the current thread until the processingStarted internal latch has counted down to zero (which happens only after processing the ControllerEvent using a ControllerEventProcessor).
|
Note
|
awaitProcessing is used exclusively when KafkaController is requested to start up.
|
String (Textual) Representation — toString Method
toString: String|
Note
|
toString is part of the java.lang.Object Contract for a string representation of the object.
|
toString returns the following string representation:
QueuedEvent(event=[event], enqueueTimeMs=[enqueueTimeMs])Internal Properties
| Name | Description |
|---|---|
|
Java’s CountDownLatch (with the count of Used when…FIXME |
|
Java’s AtomicBoolean (with the initial value of Used when…FIXME |