Class PublishEventMediator
- java.lang.Object
-
- org.wso2.carbon.mediator.service.ui.AbstractMediator
-
- org.wso2.carbon.mediator.publishevent.ui.PublishEventMediator
-
- All Implemented Interfaces:
org.wso2.carbon.mediator.service.ui.Mediator
public class PublishEventMediator extends org.wso2.carbon.mediator.service.ui.AbstractMediator
-
-
Field Summary
Fields Modifier and Type Field Description static QName
ARBITRARY_Q
static QName
ASYNC_Q
static QName
ASYNC_TIMEOUT_Q
static QName
ATTRIBUTE_Q
static QName
ATTRIBUTES_Q
static QName
CORRELATION_Q
static QName
DEFAULT_Q
static QName
EVENT_SINK_Q
static QName
META_Q
static QName
PAYLOAD_Q
static QName
STREAM_NAME_Q
static QName
STREAM_VERSION_Q
static QName
TYPE_Q
-
Constructor Summary
Constructors Constructor Description PublishEventMediator()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
build(org.apache.axiom.om.OMElement elem)
Creates the publishEvent mediator with given configuration XML as OMElementvoid
clearList(String type)
Makes Lists are EmptyList<Property>
getArbitraryProperties()
List<Property>
getCorrelationProperties()
String
getEventSink()
static QName
getExpressionAttributeQ()
List<Property>
getMetaProperties()
static QName
getNameAttributeQ()
List<Property>
getPayloadProperties()
String
getStreamName()
String
getStreamVersion()
String
getTagLocalName()
String
getTimeout()
static QName
getValueAttributeQ()
String
isAsync()
org.apache.axiom.om.OMElement
serialize(org.apache.axiom.om.OMElement parent)
Creates XML representation of the mediator as an OMElementvoid
setArbitraryProperties(List<Property> arbitraryProperties)
void
setCorrelationProperties(List<Property> correlationProperties)
void
setEventSink(String eventSink)
void
setIsAsync(String isAsync)
void
setMetaProperties(List<Property> metaProperties)
void
setPayloadProperties(List<Property> payloadProperties)
void
setStreamName(String streamName)
void
setStreamVersion(String streamVersion)
void
setTimeout(String timeout)
-
Methods inherited from class org.wso2.carbon.mediator.service.ui.AbstractMediator
collectNameValuePairs, disableStatistics, enableStatistics, getMediatorProperties, getMediatorProperties, getTraceState, isAuditConfigurable, isStatisticsEnable, processAuditStatus, saveTracingState, serializeMediatorProperties, serializeNamespaces, setAuditConfigurable, setTraceState
-
-
-
-
Field Detail
-
EVENT_SINK_Q
public static final QName EVENT_SINK_Q
-
STREAM_NAME_Q
public static final QName STREAM_NAME_Q
-
STREAM_VERSION_Q
public static final QName STREAM_VERSION_Q
-
ASYNC_Q
public static final QName ASYNC_Q
-
ASYNC_TIMEOUT_Q
public static final QName ASYNC_TIMEOUT_Q
-
ATTRIBUTES_Q
public static final QName ATTRIBUTES_Q
-
ATTRIBUTE_Q
public static final QName ATTRIBUTE_Q
-
META_Q
public static final QName META_Q
-
CORRELATION_Q
public static final QName CORRELATION_Q
-
ARBITRARY_Q
public static final QName ARBITRARY_Q
-
PAYLOAD_Q
public static final QName PAYLOAD_Q
-
TYPE_Q
public static final QName TYPE_Q
-
DEFAULT_Q
public static final QName DEFAULT_Q
-
-
Method Detail
-
getTagLocalName
public String getTagLocalName()
- Returns:
- local name of mediator
-
serialize
public org.apache.axiom.om.OMElement serialize(org.apache.axiom.om.OMElement parent)
Creates XML representation of the mediator as an OMElement- Parameters:
parent
- OMElement which take child as created OMElement
-
build
public void build(org.apache.axiom.om.OMElement elem)
Creates the publishEvent mediator with given configuration XML as OMElement- Parameters:
elem
- OMElement to be converted to publishEvent Mediator Object.
-
clearList
public void clearList(String type)
Makes Lists are Empty- Parameters:
type
- List type to be made empty
-
getStreamVersion
public String getStreamVersion()
-
getEventSink
public String getEventSink()
-
getStreamName
public String getStreamName()
-
isAsync
public String isAsync()
-
setStreamName
public void setStreamName(String streamName)
-
setStreamVersion
public void setStreamVersion(String streamVersion)
-
setEventSink
public void setEventSink(String eventSink)
-
setCorrelationProperties
public void setCorrelationProperties(List<Property> correlationProperties)
-
setIsAsync
public void setIsAsync(String isAsync)
-
getNameAttributeQ
public static QName getNameAttributeQ()
-
getValueAttributeQ
public static QName getValueAttributeQ()
-
getExpressionAttributeQ
public static QName getExpressionAttributeQ()
-
setTimeout
public void setTimeout(String timeout)
-
getTimeout
public String getTimeout()
-
-