Package | Description |
---|---|
com.espertech.esper.client |
This package and its sub-packages defines the central Esper Client APIs.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
Modifier and Type | Method and Description |
---|---|
ConfigurationEngineDefaults.Threading.Locking |
ConfigurationEngineDefaults.Threading.getInsertIntoDispatchLocking()
Returns the blocking strategy to use when multiple threads deliver results for
a single statement to consuming statements of an insert-into, and the guarantee of order of delivery must be maintained.
|
ConfigurationEngineDefaults.Threading.Locking |
ConfigurationEngineDefaults.Threading.getListenerDispatchLocking()
Returns the blocking strategy to use when multiple threads deliver results for
a single statement to listeners, and the guarantee of order of delivery must be maintained.
|
ConfigurationEngineDefaults.Threading.Locking |
ConfigurationEngineDefaults.Threading.getNamedWindowConsumerDispatchLocking()
Returns the locking strategy value for named window dispatches to named window consumers (default is spin).
|
static ConfigurationEngineDefaults.Threading.Locking |
ConfigurationEngineDefaults.Threading.Locking.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ConfigurationEngineDefaults.Threading.Locking[] |
ConfigurationEngineDefaults.Threading.Locking.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationEngineDefaults.Threading.setInsertIntoDispatchLocking(ConfigurationEngineDefaults.Threading.Locking insertIntoDispatchLocking)
Sets the blocking strategy to use when multiple threads deliver results for
a single statement to consuming statements of an insert-into, and the guarantee of order of delivery must be maintained.
|
void |
ConfigurationEngineDefaults.Threading.setListenerDispatchLocking(ConfigurationEngineDefaults.Threading.Locking listenerDispatchLocking)
Sets the blocking strategy to use when multiple threads deliver results for
a single statement to listeners, and the guarantee of order of delivery must be maintained.
|
void |
ConfigurationEngineDefaults.Threading.setNamedWindowConsumerDispatchLocking(ConfigurationEngineDefaults.Threading.Locking namedWindowConsumerDispatchLocking)
Sets the locking strategy value for named window dispatches to named window consumers (default is spin).
|
Constructor and Description |
---|
InsertIntoLatchFactory(String name,
boolean stateless,
long msecWait,
ConfigurationEngineDefaults.Threading.Locking locking,
TimeSourceService timeSourceService)
Ctor.
|
Constructor and Description |
---|
NamedWindowConsumerLatchFactory(String name,
boolean enabled,
long msecWait,
ConfigurationEngineDefaults.Threading.Locking locking,
TimeSourceService timeSourceService,
boolean initializeNow)
Ctor.
|