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

Class UpdateDispatchViewBlockingSpin

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.UpdateDispatchViewBlockingSpin

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 UpdateDispatchViewBlockingSpin
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
UpdateDispatchViewBlockingSpin(com.espertech.esper.common.client.EventType eventType, com.espertech.esper.common.internal.context.util.StatementResultService statementResultService, com.espertech.esper.common.internal.statement.dispatch.DispatchService dispatchService, long msecTimeout, com.espertech.esper.common.internal.schedule.TimeSourceService timeSourceService) Ctor.

Method Summary

Modifier and Type	Method and Description
void	newResult(com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> result)
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

cancelled, clear, execute, getEventType, getStatementResultService, getView, 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

UpdateDispatchViewBlockingSpin

public UpdateDispatchViewBlockingSpin(com.espertech.esper.common.client.EventType eventType,
                                      com.espertech.esper.common.internal.context.util.StatementResultService statementResultService,
                                      com.espertech.esper.common.internal.statement.dispatch.DispatchService dispatchService,
                                      long msecTimeout,
                                      com.espertech.esper.common.internal.schedule.TimeSourceService timeSourceService)

Ctor.

Parameters:

dispatchService - - for performing the dispatch

msecTimeout - - timeout for preserving dispatch order through blocking

statementResultService - - handles result delivery

timeSourceService - time source provider

eventType - event type

Method Detail

update

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

Specified by:

update in interface com.espertech.esper.common.internal.view.core.View

Overrides:

update in class UpdateDispatchViewBase

newResult

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

Specified by:

newResult in interface com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView

Overrides:

newResult in class UpdateDispatchViewBase