Package | Description |
---|---|
com.streamscape.lib.dispatcher | |
com.streamscape.lib.evqueue | |
com.streamscape.sef.enums |
Modifier and Type | Method and Description |
---|---|
FlowControlMode |
EventAsyncConsumer.getFlowControlMode()
Returns a flow control mode of the underlying queue.
|
Modifier and Type | Method and Description |
---|---|
void |
EventAsyncConsumer.setFlowControlMode(FlowControlMode flowControlMode)
Sets a flow contol mode of the underlying queue.
|
Modifier and Type | Field and Description |
---|---|
static FlowControlMode |
EventQueue.DEFAULT_FLOW_CONTROL_MODE |
static FlowControlMode |
FlowControlMode.DROP
In this mode if an event queue is full, new events will not be put into the queue.
|
static FlowControlMode |
FlowControlMode.EVENT_CACHE
This mode is not supported.
|
static FlowControlMode |
FlowControlMode.EXCEPTION
In this mode if an event queue is full, an exception is thrown for every new event that users try to put into the queue.
|
static FlowControlMode |
FlowControlMode.NOTIFICATION
In this mode if an event queue is full, a notification (advisory) is raised and further enqueueing operations are blocked.
|
Modifier and Type | Method and Description |
---|---|
FlowControlMode |
EventQueue.getFlowControlMode()
Returns a flow control mode of the queue.
|
static FlowControlMode |
FlowControlMode.valueOf(java.lang.String name) |
static FlowControlMode[] |
FlowControlMode.values() |
Modifier and Type | Method and Description |
---|---|
void |
EventQueue.setFlowControlMode(FlowControlMode flowControlMode)
Sets a flow control mode of the queue.
|
Modifier and Type | Method and Description |
---|---|
FlowControlMode |
FlowControlMode.convert() |
Modifier and Type | Method and Description |
---|---|
static FlowControlMode |
FlowControlMode.convert(FlowControlMode mode) |
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.