Package | Description |
---|---|
com.streamscape.lib.dispatcher | |
com.streamscape.lib.selector.parser | |
com.streamscape.sef.evtrigger |
Modifier and Type | Method and Description |
---|---|
EventAsyncConsumer |
EventDispatcher.createAsyncConsumer(java.lang.String consumerName,
java.lang.String eventFilter,
java.lang.String eventSelector,
EventListener listener)
Creates a new event asynchronous consumer and adds this consumer to the dispatcher.
|
EventConsumer |
EventDispatcher.createConsumer(java.lang.String consumerName,
java.lang.String eventFilter,
java.lang.String eventSelector,
EventListener listener)
Creates a new event asynchronous consumer and adds this consumer to the dispatcher.
|
ImmutableEventDatagram |
EventAsyncConsumer.receive(java.lang.String eventSelector)
Returns a next event matching the specified event selector from the underlying queue.
|
ImmutableEventDatagram |
EventAsyncConsumer.receive(java.lang.String eventSelector,
long waitTime)
Returns a next event matching the specified event selector from the underlying queue.
|
ImmutableEventDatagram |
EventAsyncConsumer.receiveNoWait(java.lang.String eventSelector)
Returns a next event matching the specified event selector if one is available or
null if there are no matching
events found. |
void |
EventConsumer.setEventSelector(java.lang.String eventSelector)
Sets the event selector associated with the consumer.
|
Modifier and Type | Method and Description |
---|---|
static SelectorExpression |
SelectorParser.parse(java.lang.String expression) |
static SelectorExpression |
SelectorParser.parse(java.lang.String expression,
SelectorExternalDataSource externalDataSource) |
Modifier and Type | Method and Description |
---|---|
void |
EventTriggerDefinition.setEventSelector(java.lang.String selector) |
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.