public class LocalEntranceProcessingItem extends AbstractEntranceProcessingItem
|Constructor and Description|
|Modifier and Type||Method and Description|
If there are available events, first event in the queue will be sent out on the output stream.
Start sending events by calling
getName, getOutputStream, getProcessor, setName, setOutputStream
public LocalEntranceProcessingItem(EntranceProcessor processor)
public boolean injectNextEvent()
public void startSendingEvents()
injectNextEvent(). If there are no available events, and that the stream is not entirely consumed, it will wait by calling
waitForNewEvents()before attempting to send again. When the stream is entirely consumed, the last event is tagged accordingly and the processor gets the finished status.
Copyright © 2013–2015 The Apache Software Foundation. All rights reserved.