Package | Description |
---|---|
com.espertech.esper.common.client.configuration.runtime |
Configuration classes for the runtime section, which is only relevant to the runtime
|
com.espertech.esper.common.client.util |
Client utility classes.
|
com.espertech.esper.common.internal.epl.namedwindow.consume | |
com.espertech.esper.common.internal.statement.insertintolatch |
Modifier and Type | Method and Description |
---|---|
Locking |
ConfigurationRuntimeThreading.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.
|
Locking |
ConfigurationRuntimeThreading.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.
|
Locking |
ConfigurationRuntimeThreading.getNamedWindowConsumerDispatchLocking()
Returns the locking strategy value for named window dispatches to named window consumers (default is spin).
|
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationRuntimeThreading.setInsertIntoDispatchLocking(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 |
ConfigurationRuntimeThreading.setListenerDispatchLocking(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 |
ConfigurationRuntimeThreading.setNamedWindowConsumerDispatchLocking(Locking namedWindowConsumerDispatchLocking)
Sets the locking strategy value for named window dispatches to named window consumers (default is spin).
|
Modifier and Type | Method and Description |
---|---|
static Locking |
Locking.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Locking[] |
Locking.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
NamedWindowConsumerLatchFactory(String name,
boolean enabled,
long msecWait,
Locking locking,
TimeSourceService timeSourceService,
boolean initializeNow)
Ctor.
|
Constructor and Description |
---|
InsertIntoLatchFactory(String name,
boolean stateless,
long msecWait,
Locking locking,
TimeSourceService timeSourceService)
Ctor.
|
Copyright © 2005–2018. All rights reserved.