Package com.espertech.esper.common.internal.statement.insertintolatch

Class InsertIntoLatchFactory

java.lang.Object

com.espertech.esper.common.internal.statement.insertintolatch.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

Constructors

Constructor	Description
InsertIntoLatchFactory(String name, boolean stateless, long msecWait, Locking locking, TimeSourceService timeSourceService)	Ctor.

Method Summary

Modifier and Type	Method	Description
String	getName()
TimeSourceService	getTimeSourceService()
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 Details

InsertIntoLatchFactory

public InsertIntoLatchFactory(String name,
 boolean stateless,
 long msecWait,
 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

stateless - indicator whether stateless

Method Details

newLatch

public 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 String getName()