net.esper.client
Class ConfigurationEngineDefaults.Threading

java.lang.Object
  extended by net.esper.client.ConfigurationEngineDefaults.Threading
All Implemented Interfaces:
Serializable
Enclosing class:
ConfigurationEngineDefaults

public static class ConfigurationEngineDefaults.Threading
extends Object
implements Serializable

Holds threading settings.

See Also:
Serialized Form

Nested Class Summary
static class ConfigurationEngineDefaults.Threading.Locking
          Enumeration of blocking techniques.
 
Constructor Summary
protected ConfigurationEngineDefaults.Threading()
          Ctor - sets up defaults.
 
Method Summary
 ConfigurationEngineDefaults.Threading.Locking 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.
 long getInsertIntoDispatchTimeout()
          Returns the number of milliseconds that a thread may maximually be blocking to deliver statement results from a producing statement that employs insert-into to a consuming statement.
 long getInternalTimerMsecResolution()
          Returns the millisecond resolutuion of the internal timer thread.
 ConfigurationEngineDefaults.Threading.Locking 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.
 long getListenerDispatchTimeout()
          Returns the timeout in millisecond to wait for listener code to complete before dispatching the next result, if dispatch order is preserved
 boolean isInsertIntoDispatchPreserveOrder()
          Returns true to indicate preserve order for inter-statement insert-into, or false to indicate not to preserve order
 boolean isInternalTimerEnabled()
          Returns true if internal timer is enabled (the default), or false for internal timer disabled.
 boolean isListenerDispatchPreserveOrder()
          Returns true to indicate preserve order for dispatch to listeners, or false to indicate not to preserve order
 void 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 setInsertIntoDispatchPreserveOrder(boolean value)
          In multithreaded environments, this setting controls whether insert-into streams preserve the order of events inserted into them by one or more statements such that statements that consume other statement's events behave deterministic
 void setInsertIntoDispatchTimeout(long msecTimeout)
          Sets the number of milliseconds that a thread may maximually be blocking to deliver statement results from a producing statement that employs insert-into to a consuming statement.
 void setInternalTimerEnabled(boolean internalTimerEnabled)
          Sets the use of internal timer.
 void setInternalTimerMsecResolution(long internalTimerMsecResolution)
          Sets the length of the interval (resolution) of the timer thread.
 void 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 setListenerDispatchPreserveOrder(boolean value)
          In multithreaded environments, this setting controls whether dispatches to listeners preserve the ordering in which the statement processes events.
 void setListenerDispatchTimeout(long value)
          In multithreaded environments, this setting controls when dispatches to listeners preserve the ordering the timeout to complete any outstanding dispatches.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConfigurationEngineDefaults.Threading

protected ConfigurationEngineDefaults.Threading()
Ctor - sets up defaults.

Method Detail

setListenerDispatchPreserveOrder

public void setListenerDispatchPreserveOrder(boolean value)
In multithreaded environments, this setting controls whether dispatches to listeners preserve the ordering in which the statement processes events.

Parameters:
value - is true to preserve ordering, or false if not

setListenerDispatchTimeout

public void setListenerDispatchTimeout(long value)
In multithreaded environments, this setting controls when dispatches to listeners preserve the ordering the timeout to complete any outstanding dispatches.

Parameters:
value - is the timeout in milliseconds that the engine may spend waiting for a listener dispatch to complete before dispatching further results for the same statement to listeners for that statement

setInsertIntoDispatchPreserveOrder

public void setInsertIntoDispatchPreserveOrder(boolean value)
In multithreaded environments, this setting controls whether insert-into streams preserve the order of events inserted into them by one or more statements such that statements that consume other statement's events behave deterministic

Parameters:
value - is true to indicate to preserve order, or false to not preserve order

isListenerDispatchPreserveOrder

public boolean isListenerDispatchPreserveOrder()
Returns true to indicate preserve order for dispatch to listeners, or false to indicate not to preserve order

Returns:
true or false

getListenerDispatchTimeout

public long getListenerDispatchTimeout()
Returns the timeout in millisecond to wait for listener code to complete before dispatching the next result, if dispatch order is preserved

Returns:
listener dispatch timeout

isInsertIntoDispatchPreserveOrder

public boolean isInsertIntoDispatchPreserveOrder()
Returns true to indicate preserve order for inter-statement insert-into, or false to indicate not to preserve order

Returns:
true or false

setInternalTimerEnabled

public void setInternalTimerEnabled(boolean internalTimerEnabled)
Sets the use of internal timer.

By setting internal timer to true (the default) the engine starts the internal timer thread and relies on internal timer events to supply the time.

By setting internal timer to false the engine does not start the internal timer thread and relies on external application-supplied timer events to supply the time.

Parameters:
internalTimerEnabled - is true for internal timer enabled, or false if the application supplies timer events

isInternalTimerEnabled

public boolean isInternalTimerEnabled()
Returns true if internal timer is enabled (the default), or false for internal timer disabled.

Returns:
true for internal timer enabled, false for internal timer disabled

getInternalTimerMsecResolution

public long getInternalTimerMsecResolution()
Returns the millisecond resolutuion of the internal timer thread.

Returns:
number of msec between timer processing intervals

setInternalTimerMsecResolution

public void setInternalTimerMsecResolution(long internalTimerMsecResolution)
Sets the length of the interval (resolution) of the timer thread.

Parameters:
internalTimerMsecResolution - is the millisecond interval length

getInsertIntoDispatchTimeout

public long getInsertIntoDispatchTimeout()
Returns the number of milliseconds that a thread may maximually be blocking to deliver statement results from a producing statement that employs insert-into to a consuming statement.

Returns:
millisecond timeout for order-of-delivery blocking between statements

setListenerDispatchLocking

public void 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.

Parameters:
listenerDispatchLocking - is the blocking technique

setInsertIntoDispatchTimeout

public void setInsertIntoDispatchTimeout(long msecTimeout)
Sets the number of milliseconds that a thread may maximually be blocking to deliver statement results from a producing statement that employs insert-into to a consuming statement.

Parameters:
msecTimeout - timeout for order-of-delivery blocking between statements

setInsertIntoDispatchLocking

public void 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.

Parameters:
insertIntoDispatchLocking - is the blocking technique

getListenerDispatchLocking

public ConfigurationEngineDefaults.Threading.Locking 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.

Returns:
is the blocking technique

getInsertIntoDispatchLocking

public ConfigurationEngineDefaults.Threading.Locking 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.

Returns:
is the blocking technique

© 2007 EsperTech Inc.
All rights reserved.
Visit us at espertech.com