com.espertech.esper.runtime.internal.kernel.updatedispatch

Class UpdateDispatchViewBlockingWait

java.lang.Object

com.espertech.esper.common.internal.view.core.ViewSupport

com.espertech.esper.runtime.internal.kernel.updatedispatch.UpdateDispatchViewBase

com.espertech.esper.runtime.internal.kernel.updatedispatch.UpdateDispatchViewBlockingWait

All Implemented Interfaces:

com.espertech.esper.common.internal.statement.dispatch.Dispatchable, com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView, com.espertech.esper.common.internal.view.core.View, com.espertech.esper.common.internal.view.core.Viewable, Iterable<com.espertech.esper.common.client.EventBean>

public class UpdateDispatchViewBlockingWait
extends UpdateDispatchViewBase

Convenience view for dispatching view updates received from a parent view to update listeners via the dispatch service.

Field Summary

Fields inherited from class com.espertech.esper.runtime.internal.kernel.updatedispatch.UpdateDispatchViewBase

dispatchService, eventType, lastIterableEvent, statementResultService

Fields inherited from class com.espertech.esper.common.internal.view.core.ViewSupport

child, parent

Constructor Summary

Constructors

Constructor and Description
UpdateDispatchViewBlockingWait(com.espertech.esper.common.client.EventType eventType, com.espertech.esper.common.internal.context.util.StatementResultService statementResultServiceImpl, com.espertech.esper.common.internal.statement.dispatch.DispatchService dispatchService, long msecTimeout) Ctor.

Method Summary

Modifier and Type	Method and Description
void	newResult(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> results)
void	update(com.espertech.esper.common.client.EventBean[] newData, com.espertech.esper.common.client.EventBean[] oldData)

Methods inherited from class com.espertech.esper.runtime.internal.kernel.updatedispatch.UpdateDispatchViewBase

clear, execute, getEventType, getStatementResultService, iterator

Methods inherited from class com.espertech.esper.common.internal.view.core.ViewSupport

getChild, getParent, setChild, setParent

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.common.internal.view.core.View

getParent, setParent

Methods inherited from interface com.espertech.esper.common.internal.view.core.Viewable

getChild, setChild

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

UpdateDispatchViewBlockingWait

public UpdateDispatchViewBlockingWait(com.espertech.esper.common.client.EventType eventType,
                                      com.espertech.esper.common.internal.context.util.StatementResultService statementResultServiceImpl,
                                      com.espertech.esper.common.internal.statement.dispatch.DispatchService dispatchService,
                                      long msecTimeout)

Ctor.

Parameters:

dispatchService - - for performing the dispatch

msecTimeout - - timeout for preserving dispatch order through blocking

statementResultServiceImpl - - handles result delivery

eventType - event type

Method Detail

update

public void update(com.espertech.esper.common.client.EventBean[] newData,
                   com.espertech.esper.common.client.EventBean[] oldData)

newResult

public void newResult(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> results)