com.espertech.esper.epl.named
Class NamedWindowConsumerLatchFactory

java.lang.Object
  com.espertech.esper.epl.named.NamedWindowConsumerLatchFactory

public class NamedWindowConsumerLatchFactory
extends java.lang.Object

Class to hold a current latch per named window.

Constructor Summary

NamedWindowConsumerLatchFactory(java.lang.String name, boolean enabled, long msecWait, ConfigurationEngineDefaults.Threading.Locking locking, TimeSourceService timeSourceService)
Ctor.

Method Summary

long	getMsecWait()
java.lang.String	getName()
TimeSourceService	getTimeSourceService()
NamedWindowConsumerLatch	newLatch(NamedWindowDeltaData delta, java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumers) Returns a new latch.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NamedWindowConsumerLatchFactory

public NamedWindowConsumerLatchFactory(java.lang.String name,
                                       boolean enabled,
                                       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 NamedWindowConsumerLatch newLatch(NamedWindowDeltaData delta,
                                         java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumers)

Returns a new latch.

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

Returns:

latch

getTimeSourceService

public TimeSourceService getTimeSourceService()

getName

public java.lang.String getName()

getMsecWait

public long getMsecWait()