Class PublishEventMediator
- java.lang.Object
-
- org.apache.synapse.mediators.AbstractMediator
-
- org.wso2.carbon.mediator.publishevent.PublishEventMediator
-
- All Implemented Interfaces:
org.apache.synapse.aspects.AspectConfigurable
,org.apache.synapse.Mediator
,org.apache.synapse.SynapseArtifact
public class PublishEventMediator extends org.apache.synapse.mediators.AbstractMediator
Mediator that extracts data from current message payload/header according to the given configuration. Extracted information is sent as an event.
-
-
Constructor Summary
Constructors Constructor Description PublishEventMediator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<Property>
getArbitraryProperties()
long
getAsyncTimeout()
List<Property>
getCorrelationProperties()
org.wso2.carbon.event.sink.EventSink
getEventSink()
String
getEventSinkName()
List<Property>
getMetaProperties()
List<Property>
getPayloadProperties()
String
getStreamName()
String
getStreamVersion()
boolean
isAsync()
boolean
isContentAware()
boolean
mediate(org.apache.synapse.MessageContext messageContext)
This is called when a new message is received for mediation.void
setArbitraryProperties(List<Property> arbitraryProperties)
void
setAsync(boolean async)
void
setAsyncTimeout(long asyncTimeout)
void
setCorrelationProperties(List<Property> correlationProperties)
void
setEventSink(org.wso2.carbon.event.sink.EventSink eventSink)
void
setEventSinkName(String eventSinkName)
void
setMetaProperties(List<Property> metaProperties)
void
setPayloadProperties(List<Property> payloadProperties)
void
setStreamName(String streamName)
void
setStreamVersion(String streamVersion)
-
Methods inherited from class org.apache.synapse.mediators.AbstractMediator
auditLog, auditWarn, configure, disableStatistics, disableTracing, divertMediationRoute, enableStatistics, enableTracing, getAspectConfiguration, getCommentsList, getDescription, getInputType, getLastSequenceFaultHandler, getLog, getMediatorName, getMediatorPosition, getOutputType, getRegisteredMediationFlowPoint, getShortDescription, getTraceState, getType, handleException, handleException, isBreakPoint, isContentAltering, isSkipEnabled, isStatisticsEnable, isTraceOn, isTraceOrDebugOn, isTracingEnabled, registerMediationFlowPoint, reportCloseStatistics, reportOpenStatistics, setBreakPoint, setCommentsList, setComponentStatisticsId, setDescription, setEffectiveTraceState, setMediatorPosition, setShortDescription, setSkipEnabled, setTraceState, shouldCaptureTracing, shouldTrace, shouldTrace, traceOrDebug, traceOrDebugWarn, unregisterMediationFlowPoint
-
-
-
-
Method Detail
-
isContentAware
public boolean isContentAware()
- Specified by:
isContentAware
in interfaceorg.apache.synapse.Mediator
- Overrides:
isContentAware
in classorg.apache.synapse.mediators.AbstractMediator
-
mediate
public boolean mediate(org.apache.synapse.MessageContext messageContext)
This is called when a new message is received for mediation. Extracts data from message to construct an event based on the mediator configuration Sends the constructed event to the event sink specified in mediator configuration- Parameters:
messageContext
- Message context of the message to be mediated- Returns:
- Always returns true. (instructs to proceed with next mediator)
-
getEventSink
public org.wso2.carbon.event.sink.EventSink getEventSink()
-
getEventSinkName
public String getEventSinkName()
-
getStreamName
public String getStreamName()
-
getStreamVersion
public String getStreamVersion()
-
setEventSink
public void setEventSink(org.wso2.carbon.event.sink.EventSink eventSink)
-
setEventSinkName
public void setEventSinkName(String eventSinkName)
-
setStreamName
public void setStreamName(String streamName)
-
setStreamVersion
public void setStreamVersion(String streamVersion)
-
setCorrelationProperties
public void setCorrelationProperties(List<Property> correlationProperties)
-
setAsync
public void setAsync(boolean async)
-
isAsync
public boolean isAsync()
-
getAsyncTimeout
public long getAsyncTimeout()
-
setAsyncTimeout
public void setAsyncTimeout(long asyncTimeout)
-
-