Package | Description |
---|---|
com.streamscape.lib.dispatcher | |
com.streamscape.lib.evqueue |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
EventAsyncConsumer.receive()
Returns a next available event in the event queue.
|
ImmutableEventDatagram |
EventAsyncConsumer.receive(long waitTime)
Returns a next available event from the underlying queue.
|
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.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
EventQueue.dequeue()
Dequeues an object, expecting an appearance of this object in the queue during unlimited time interval.
|
java.lang.Object |
EventQueue.dequeue(long waitTime)
Dequeues an object, expecting an appearance of this object in the queue during the specified time interval.
|
java.lang.Object |
EventQueue.dequeue(Matcher matcher)
Dequeues an object, expecting an appearance of this object in the queue during unlimited time interval.
|
java.lang.Object |
EventQueue.dequeue(Matcher matcher,
long waitTime)
Dequeues an object, expecting an appearance of this object in the queue during the specified time interval.
|
java.util.List |
EventQueue.dequeueList(int objectsNumber)
Dequeues the specified number of objects, expecting an appearance of these objects in the queue during unlimited time interval.
|
java.util.List |
EventQueue.dequeueList(int objectsNumber,
long waitTime)
Dequeues the specified number of objects, expecting an appearance of these objects in the queue during the specified time interval.
|
java.util.List |
EventQueue.drain()
Dequeues all objects, expecting an appearance at least of one object in the queue during unlimited time interval.
|
java.util.List |
EventQueue.drain(long waitTime)
Dequeues all objects, expecting an appearance at least of one object in the queue during the specified time interval.
|
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.