Package com.espertech.esper.runtime.internal.subscriber

Class ResultDeliveryStrategyFactory

java.lang.Object

com.espertech.esper.runtime.internal.subscriber.ResultDeliveryStrategyFactory

public class ResultDeliveryStrategyFactory
extends Object

Factory for creating a dispatch strategy based on the subscriber object and the columns produced by a select-clause.

Constructor Summary

Constructors

Constructor	Description
ResultDeliveryStrategyFactory()

Method Summary

Modifier and Type	Method	Description
static ResultDeliveryStrategy	create(EPStatement statement, Object subscriber, String methodName, Class[] selectClauseTypes, String[] selectClauseColumns, String runtimeURI, com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)	Creates a strategy implementation that indicates to subscribers the statement results based on the select-clause columns.

Methods inherited from class java.lang.Object

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

Constructor Details

ResultDeliveryStrategyFactory

public ResultDeliveryStrategyFactory()

Method Details

create

public static ResultDeliveryStrategy create(EPStatement statement,
 Object subscriber,
 String methodName,
 Class[] selectClauseTypes,
 String[] selectClauseColumns,
 String runtimeURI,
 com.espertech.esper.common.internal.settings.ClasspathImportService classpathImportService)
                                     throws ResultDeliveryStrategyInvalidException

Creates a strategy implementation that indicates to subscribers the statement results based on the select-clause columns.

Parameters:

subscriber - to indicate to

selectClauseTypes - are the types of each column in the select clause

selectClauseColumns - the names of each column in the select clause

statement - statement

methodName - method name

runtimeURI - runtime URI

classpathImportService - runtime imports

Returns:

strategy for dispatching naturals

Throws:

ResultDeliveryStrategyInvalidException - if the subscriber is invalid