public class PublishEventMediator
extends org.apache.synapse.mediators.AbstractMediator
Constructor and Description |
---|
PublishEventMediator() |
Modifier and Type | Method and Description |
---|---|
List<Property> |
getArbitraryProperties() |
protected long |
getAsyncTimeout() |
List<Property> |
getCorrelationProperties() |
org.wso2.carbon.event.sink.EventSink |
getEventSink() |
String |
getEventSinkName() |
List<Property> |
getMetaProperties() |
List<Property> |
getPayloadProperties() |
String |
getStreamName() |
String |
getStreamVersion() |
protected 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) |
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
public boolean isContentAware()
isContentAware
in interface org.apache.synapse.Mediator
isContentAware
in class org.apache.synapse.mediators.AbstractMediator
public boolean mediate(org.apache.synapse.MessageContext messageContext)
messageContext
- Message context of the message to be mediatedpublic org.wso2.carbon.event.sink.EventSink getEventSink()
public String getEventSinkName()
public String getStreamName()
public String getStreamVersion()
public void setEventSink(org.wso2.carbon.event.sink.EventSink eventSink)
public void setEventSinkName(String eventSinkName)
public void setStreamName(String streamName)
public void setStreamVersion(String streamVersion)
public void setAsync(boolean async)
protected boolean isAsync()
protected long getAsyncTimeout()
public void setAsyncTimeout(long asyncTimeout)
Copyright © 2017 WSO2. All rights reserved.