Class SynapseEventSource

  • All Implemented Interfaces:
    org.apache.axis2.engine.MessageReceiver

    public class SynapseEventSource
    extends SynapseMessageReceiver
    Eventsource that accepts the event requests using a message receiver. Eventsource is responsible on two tasks accepting the subscriptions and subscription related reqests and dispatching events. Subscriptions contains operations listed in the WS-Eventing specification. {SubscribeOP, UnsubscribeOP, RenewOP, GetstatusOP, SubscriptionEndOP} based on the action in the request eventsource identify the operation and send it for processing. Eventsource link with a subscription manager to store the subscriptions.
    • Constructor Detail

      • SynapseEventSource

        public SynapseEventSource​(String name)
    • Method Detail

      • getName

        public String getName()
      • setName

        public void setName​(String name)
      • getSubscriptionManager

        public org.wso2.eventing.SubscriptionManager getSubscriptionManager()
      • setSubscriptionManager

        public void setSubscriptionManager​(org.wso2.eventing.SubscriptionManager subscriptionManager)
      • getFileName

        public String getFileName()
      • setFileName

        public void setFileName​(String fileName)
      • buildService

        public void buildService​(org.apache.axis2.engine.AxisConfiguration axisCfg)
                          throws org.apache.axis2.AxisFault
        Throws:
        org.apache.axis2.AxisFault
      • receive

        public void receive​(org.apache.axis2.context.MessageContext mc)
                     throws org.apache.axis2.AxisFault
        Override the Message receiver method to accept subscriptions and events
        Specified by:
        receive in interface org.apache.axis2.engine.MessageReceiver
        Overrides:
        receive in class SynapseMessageReceiver
        Parameters:
        mc - message context
        Throws:
        org.apache.axis2.AxisFault
      • dispatchEvents

        public void dispatchEvents​(MessageContext msgCtx)
        Public method for event dispatching, used by the eventPublisher mediator and eventSource
        Parameters:
        msgCtx - message context
      • putConfigurationProperty

        public void putConfigurationProperty​(String name,
                                             String value)
      • getConfigurationProperty

        public String getConfigurationProperty​(String name)
      • isContainsConfigurationProperty

        public boolean isContainsConfigurationProperty​(String name)