Package 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

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

    EPTYPE

  • Constructor Summary

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

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