@NoImplement public interface Sink extends Consumer<CoreEvent>
CoreEvent
's asynchronously for processing. The result of asynchronous processing can be obtained
by subscribing to the CoreEvent
's BaseEventContext
.
All Sinks must support concurrent calls from multiple publishers and it is then up to each implementation to determine how to
handle this, i.e.
Modifier and Type | Method and Description |
---|---|
void |
accept(CoreEvent event)
Submit the given
CoreEvent for processing without a timeout. |
boolean |
emit(CoreEvent event)
Submit the given
CoreEvent for processing. |
Copyright © 2018. All rights reserved.