com.espertech.esper.core.service
Class InsertIntoLatchFactory

java.lang.Object
  com.espertech.esper.core.service.InsertIntoLatchFactory

public class InsertIntoLatchFactory
extends java.lang.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(java.lang.String name, long msecWait, ConfigurationEngineDefaults.Threading.Locking locking, TimeSourceService timeSourceService)
Ctor.

Method Summary

java.lang.String	getName()
TimeSourceService	getTimeSourceService()
java.lang.Object	newLatch(EventBean 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(java.lang.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 java.lang.Object newLatch(EventBean 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

getTimeSourceService

public TimeSourceService getTimeSourceService()

getName

public java.lang.String getName()