public class TriggerFunctionContextImpl extends com.streamscape.sef.evtrigger.function.TriggerFunctionParserContextImpl implements TriggerFunctionContext
Title: Service Event Fabric Runtime
Description: Trigger function context implementation.
Copyright: Copyright (c) 2013
Company: StreamScape Technologies
Modifier and Type | Class and Description |
---|---|
static interface |
TriggerFunctionContextImpl.DataspaceAccessorProvider |
Constructor and Description |
---|
TriggerFunctionContextImpl(FabricContext context) |
addSystemVariableType, addSystemVariableType, createEvent, existsSemanticType, existsSemanticTypeByClass, existsSystemVariableType, getActionableEventType, getFabricContext, getSystemVariableType, isCompleteMode, listSemanticTypes, loadClass, loadClass, lookupEventPrototype, lookupSemanticType, lookupSemanticTypeByClass, needToReload, needToReload, needToReload, setActionableEventAlias, setActionableEventType, setActionableEventType, setActionableEventType, setCompleteMode, setSourceEventAlias, setSourceEventAlias, validateSystemVariableTypes
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createEvent
existsSemanticType, existsSemanticTypeByClass, existsSystemVariableType, getActionableEventType, getFabricContext, getSystemVariableType, isCompleteMode, listSemanticTypes, loadClass, loadClass, lookupEventPrototype, lookupSemanticType, lookupSemanticTypeByClass, needToReload, needToReload, needToReload, setCompleteMode
public TriggerFunctionContextImpl(FabricContext context)
public void setComponent(FabricComponent component) throws java.lang.Exception
java.lang.Exception
public FabricComponent getComponent()
getComponent
in interface TriggerFunctionContext
public void raiseEvent(ImmutableEventDatagram event, EventScope eventScope) throws java.lang.Exception
raiseEvent
in interface TriggerFunctionContext
java.lang.Exception
public void raiseEvent(ImmutableEventDatagram event) throws java.lang.Exception
raiseEvent
in interface TriggerFunctionContext
java.lang.Exception
public java.lang.Object getSystemVariableValue(java.lang.String name)
getSystemVariableValue
in interface TriggerFunctionContext
public boolean existsSystemVariableValue(java.lang.String name)
existsSystemVariableValue
in interface TriggerFunctionContext
public void setSystemVariableValue(java.lang.String name, java.lang.Object value) throws TriggerFunctionException
TriggerFunctionException
public void setEventTriggerDefinition(EventTriggerDefinition eventTriggerDefinition)
public EventTriggerDefinition getEventTriggerDefinition()
getEventTriggerDefinition
in interface TriggerFunctionContext
public void setActionableEvent(ImmutableEventDatagram actionableEvent) throws TriggerFunctionException
TriggerFunctionException
public ImmutableEventDatagram getActionableEvent()
getActionableEvent
in interface TriggerFunctionContext
public void setSourceEvent(ImmutableEventDatagram sourceEvent)
public ImmutableEventDatagram getSourceEvent()
public AcknowledgementEvent createAcknowledgement(ImmutableEventDatagram event, boolean withSourceData) throws java.lang.Exception
createAcknowledgement
in interface TriggerFunctionContext
java.lang.Exception
public AcknowledgementEvent createAcknowledgement(java.lang.String eventId) throws java.lang.Exception
createAcknowledgement
in interface TriggerFunctionContext
java.lang.Exception
public ConverterPluginManager getConverterPluginManager()
getConverterPluginManager
in interface TriggerFunctionContext
public EventDatagramFactory getEventDatagramFactory()
getEventDatagramFactory
in interface TriggerFunctionContext
public DataspaceAccessor createDataspaceAccessor(java.lang.String componentName) throws java.lang.Exception
createDataspaceAccessor
in interface TriggerFunctionContext
java.lang.Exception
public ServiceAccessor createServiceAccessor(java.lang.String componentName) throws java.lang.Exception
createServiceAccessor
in interface TriggerFunctionContext
java.lang.Exception
public SLSession createSLSession(java.lang.String nodeName) throws java.lang.Exception
createSLSession
in interface TriggerFunctionContext
java.lang.Exception
public SLSession getSLSession() throws java.lang.Exception
getSLSession
in interface TriggerFunctionContext
java.lang.Exception
public void closeSLSession()
public void setExecutionWindowMs(long executionWindowMs)
public long getExecutionWindowMs()
getExecutionWindowMs
in interface TriggerFunctionContext
public TriggerFunctionContextImpl setDataspaceAccessorProvider(TriggerFunctionContextImpl.DataspaceAccessorProvider dataspaceAccessorProvider)
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.