com.espertech.esper.core
Class InsertIntoLatchFactory

java.lang.Object
  extended by com.espertech.esper.core.InsertIntoLatchFactory

public class InsertIntoLatchFactory
extends Object

Class to hold a current latch per statement that uses an insert-into stream (per statement and insert-into stream relationship).


Constructor Summary
InsertIntoLatchFactory(String name, long msecWait, ConfigurationEngineDefaults.Threading.Locking locking, TimeSourceService timeSourceService)
          Ctor.
 
Method Summary
 Object newLatch(Object payload)
          Returns a new latch.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

InsertIntoLatchFactory

public InsertIntoLatchFactory(String name,
                              long msecWait,
                              ConfigurationEngineDefaults.Threading.Locking locking,
                              TimeSourceService timeSourceService)
Ctor.

Parameters:
name - the factory name
msecWait - the number of milliseconds latches will await maximually
locking - the blocking strategy to employ
timeSourceService - time source provider
Method Detail

newLatch

public Object newLatch(Object payload)
Returns a new latch.

Need not be synchronized as there is one per statement and execution is during statement lock.

Parameters:
payload - is the object returned by the await.
Returns:
latch

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