Class PublishEventMediator

  • All Implemented Interfaces:
    org.wso2.carbon.mediator.service.ui.Mediator

    public class PublishEventMediator
    extends org.wso2.carbon.mediator.service.ui.AbstractMediator
    • 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
    • Constructor Detail

      • PublishEventMediator

        public PublishEventMediator()
    • 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()
      • getMetaProperties

        public List<Property> getMetaProperties()
      • getCorrelationProperties

        public List<Property> getCorrelationProperties()
      • getPayloadProperties

        public List<Property> getPayloadProperties()
      • getArbitraryProperties

        public List<Property> getArbitraryProperties()
      • 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)
      • setMetaProperties

        public void setMetaProperties​(List<Property> metaProperties)
      • setCorrelationProperties

        public void setCorrelationProperties​(List<Property> correlationProperties)
      • setIsAsync

        public void setIsAsync​(String isAsync)
      • setPayloadProperties

        public void setPayloadProperties​(List<Property> payloadProperties)
      • setArbitraryProperties

        public void setArbitraryProperties​(List<Property> arbitraryProperties)
      • 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()