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

Constructor Summary
protected ConfigurationEngineDefaults.Threading()
          Ctor - sets up defaults.
 
Method Summary
 long getInternalTimerMsecResolution()
          Returns the millisecond resolutuion of the internal timer thread.
 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 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 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 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