org.apache.synapse.eventing.managers
Class DefaultInMemorySubscriptionManager
java.lang.Object
org.apache.synapse.eventing.managers.DefaultInMemorySubscriptionManager
- All Implemented Interfaces:
- org.wso2.eventing.SubscriptionManager<MessageContext>
public class DefaultInMemorySubscriptionManager
- extends Object
- implements org.wso2.eventing.SubscriptionManager<MessageContext>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultInMemorySubscriptionManager
public DefaultInMemorySubscriptionManager()
getStaticSubscriptions
public List<org.wso2.eventing.Subscription> getStaticSubscriptions()
- Specified by:
getStaticSubscriptions
in interface org.wso2.eventing.SubscriptionManager<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<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<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<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<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<MessageContext>
- Throws:
org.wso2.eventing.exceptions.EventException
getMatchingSubscriptions
public List<org.wso2.eventing.Subscription> getMatchingSubscriptions(org.wso2.eventing.Event<MessageContext> event)
throws org.wso2.eventing.exceptions.EventException
- Specified by:
getMatchingSubscriptions
in interface org.wso2.eventing.SubscriptionManager<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<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<MessageContext>
- Throws:
org.wso2.eventing.exceptions.EventException
init
public void init()
- Specified by:
init
in interface org.wso2.eventing.SubscriptionManager<MessageContext>
addProperty
public void addProperty(String name,
String value)
- Specified by:
addProperty
in interface org.wso2.eventing.SubscriptionManager<MessageContext>
getPropertyNames
public Collection<String> getPropertyNames()
- Specified by:
getPropertyNames
in interface org.wso2.eventing.SubscriptionManager<MessageContext>
getPropertyValue
public String getPropertyValue(String name)
- Specified by:
getPropertyValue
in interface org.wso2.eventing.SubscriptionManager<MessageContext>
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.