Class DefaultInMemorySubscriptionManager
- java.lang.Object
-
- org.apache.synapse.eventing.managers.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 Summary
Constructors Constructor Description DefaultInMemorySubscriptionManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addProperty(String name, String value)
List<org.wso2.eventing.Subscription>
getAllSubscriptions()
List<org.wso2.eventing.Subscription>
getMatchingSubscriptions(org.wso2.eventing.Event<org.apache.axis2.context.MessageContext> event)
Collection<String>
getPropertyNames()
String
getPropertyValue(String name)
List<org.wso2.eventing.Subscription>
getStaticSubscriptions()
org.wso2.eventing.Subscription
getStatus(String s)
org.wso2.eventing.Subscription
getSubscription(String id)
List<org.wso2.eventing.Subscription>
getSubscriptions()
void
init()
boolean
renew(org.wso2.eventing.Subscription subscription)
String
subscribe(org.wso2.eventing.Subscription subscription)
boolean
unsubscribe(String id)
-
-
-
Method Detail
-
getStaticSubscriptions
public List<org.wso2.eventing.Subscription> getStaticSubscriptions()
- Specified by:
getStaticSubscriptions
in interfaceorg.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 interfaceorg.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 interfaceorg.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 interfaceorg.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 interfaceorg.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 interfaceorg.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 interfaceorg.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 interfaceorg.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 interfaceorg.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
- Throws:
org.wso2.eventing.exceptions.EventException
-
init
public void init()
- Specified by:
init
in interfaceorg.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
-
addProperty
public void addProperty(String name, String value)
- Specified by:
addProperty
in interfaceorg.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
-
getPropertyNames
public Collection<String> getPropertyNames()
- Specified by:
getPropertyNames
in interfaceorg.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
-
-