Class DefaultInMemorySubscriptionManager

  • All Implemented Interfaces:
    org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>

    public class DefaultInMemorySubscriptionManager
    extends Object
    implements org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
    • Constructor Detail

      • DefaultInMemorySubscriptionManager

        public DefaultInMemorySubscriptionManager()
    • Method Detail

      • getStaticSubscriptions

        public List<org.wso2.eventing.Subscription> getStaticSubscriptions()
        Specified by:
        getStaticSubscriptions in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
      • subscribe

        public String subscribe​(org.wso2.eventing.Subscription subscription)
                         throws org.wso2.eventing.exceptions.EventException
        Specified by:
        subscribe in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
        Throws:
        org.wso2.eventing.exceptions.EventException
      • unsubscribe

        public boolean unsubscribe​(String id)
                            throws org.wso2.eventing.exceptions.EventException
        Specified by:
        unsubscribe in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
        Throws:
        org.wso2.eventing.exceptions.EventException
      • renew

        public boolean renew​(org.wso2.eventing.Subscription subscription)
                      throws org.wso2.eventing.exceptions.EventException
        Specified by:
        renew in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
        Throws:
        org.wso2.eventing.exceptions.EventException
      • getSubscriptions

        public List<org.wso2.eventing.Subscription> getSubscriptions()
                                                              throws org.wso2.eventing.exceptions.EventException
        Specified by:
        getSubscriptions in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
        Throws:
        org.wso2.eventing.exceptions.EventException
      • getAllSubscriptions

        public List<org.wso2.eventing.Subscription> getAllSubscriptions()
                                                                 throws org.wso2.eventing.exceptions.EventException
        Specified by:
        getAllSubscriptions in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
        Throws:
        org.wso2.eventing.exceptions.EventException
      • getMatchingSubscriptions

        public List<org.wso2.eventing.Subscription> getMatchingSubscriptions​(org.wso2.eventing.Event<org.apache.axis2.context.MessageContext> event)
                                                                      throws org.wso2.eventing.exceptions.EventException
        Specified by:
        getMatchingSubscriptions in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
        Throws:
        org.wso2.eventing.exceptions.EventException
      • getSubscription

        public org.wso2.eventing.Subscription getSubscription​(String id)
        Specified by:
        getSubscription in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
      • getStatus

        public org.wso2.eventing.Subscription getStatus​(String s)
                                                 throws org.wso2.eventing.exceptions.EventException
        Specified by:
        getStatus in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
        Throws:
        org.wso2.eventing.exceptions.EventException
      • init

        public void init()
        Specified by:
        init in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
      • addProperty

        public void addProperty​(String name,
                                String value)
        Specified by:
        addProperty in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
      • getPropertyNames

        public Collection<String> getPropertyNames()
        Specified by:
        getPropertyNames in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
      • getPropertyValue

        public String getPropertyValue​(String name)
        Specified by:
        getPropertyValue in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>