Package 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

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

    EPTYPE

  • Constructor Summary

    Constructors
    Constructor
    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
    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

    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 java.lang.Iterable

    forEach, spliterator

    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

  • Constructor Details

    • 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 Details

    • 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[]> results)
      Specified by:
      newResult in interface com.espertech.esper.common.internal.statement.dispatch.UpdateDispatchView
      Overrides:
      newResult in class UpdateDispatchViewBase