public class StreamHandler extends Object implements com.lmax.disruptor.EventHandler<EventExchangeHolder>
Constructor and Description |
---|
StreamHandler(List<StreamJunction.Receiver> receivers,
int batchSize,
String streamName,
String siddhiAppName,
StreamJunction faultStreamJunction,
StreamJunction.OnErrorAction onErrorAction,
ExceptionListener exceptionListener) |
Modifier and Type | Method and Description |
---|---|
void |
onEvent(EventExchangeHolder eventExchangeHolder,
long sequence,
boolean endOfBatch) |
public StreamHandler(List<StreamJunction.Receiver> receivers, int batchSize, String streamName, String siddhiAppName, StreamJunction faultStreamJunction, StreamJunction.OnErrorAction onErrorAction, ExceptionListener exceptionListener)
public void onEvent(EventExchangeHolder eventExchangeHolder, long sequence, boolean endOfBatch)
onEvent
in interface com.lmax.disruptor.EventHandler<EventExchangeHolder>
Copyright © 2021. All rights reserved.