public class DefaultInMemorySubscriptionManager
extends java.lang.Object
implements org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
Constructor and Description |
---|
DefaultInMemorySubscriptionManager() |
Modifier and Type | Method and Description |
---|---|
void |
addProperty(java.lang.String name,
java.lang.String value) |
java.util.List<org.wso2.eventing.Subscription> |
getAllSubscriptions() |
java.util.List<org.wso2.eventing.Subscription> |
getMatchingSubscriptions(org.wso2.eventing.Event<org.apache.axis2.context.MessageContext> event) |
java.util.Collection<java.lang.String> |
getPropertyNames() |
java.lang.String |
getPropertyValue(java.lang.String name) |
java.util.List<org.wso2.eventing.Subscription> |
getStaticSubscriptions() |
org.wso2.eventing.Subscription |
getStatus(java.lang.String s) |
org.wso2.eventing.Subscription |
getSubscription(java.lang.String id) |
java.util.List<org.wso2.eventing.Subscription> |
getSubscriptions() |
void |
init() |
boolean |
renew(org.wso2.eventing.Subscription subscription) |
java.lang.String |
subscribe(org.wso2.eventing.Subscription subscription) |
boolean |
unsubscribe(java.lang.String id) |
public java.util.List<org.wso2.eventing.Subscription> getStaticSubscriptions()
getStaticSubscriptions
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
public java.lang.String subscribe(org.wso2.eventing.Subscription subscription) throws org.wso2.eventing.exceptions.EventException
subscribe
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
org.wso2.eventing.exceptions.EventException
public boolean unsubscribe(java.lang.String id) throws org.wso2.eventing.exceptions.EventException
unsubscribe
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
org.wso2.eventing.exceptions.EventException
public boolean renew(org.wso2.eventing.Subscription subscription) throws org.wso2.eventing.exceptions.EventException
renew
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
org.wso2.eventing.exceptions.EventException
public java.util.List<org.wso2.eventing.Subscription> getSubscriptions() throws org.wso2.eventing.exceptions.EventException
getSubscriptions
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
org.wso2.eventing.exceptions.EventException
public java.util.List<org.wso2.eventing.Subscription> getAllSubscriptions() throws org.wso2.eventing.exceptions.EventException
getAllSubscriptions
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
org.wso2.eventing.exceptions.EventException
public java.util.List<org.wso2.eventing.Subscription> getMatchingSubscriptions(org.wso2.eventing.Event<org.apache.axis2.context.MessageContext> event) throws org.wso2.eventing.exceptions.EventException
getMatchingSubscriptions
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
org.wso2.eventing.exceptions.EventException
public org.wso2.eventing.Subscription getSubscription(java.lang.String id)
getSubscription
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
public org.wso2.eventing.Subscription getStatus(java.lang.String s) throws org.wso2.eventing.exceptions.EventException
getStatus
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
org.wso2.eventing.exceptions.EventException
public void init()
init
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
public void addProperty(java.lang.String name, java.lang.String value)
addProperty
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
public java.util.Collection<java.lang.String> getPropertyNames()
getPropertyNames
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
public java.lang.String getPropertyValue(java.lang.String name)
getPropertyValue
in interface org.wso2.eventing.SubscriptionManager<org.apache.axis2.context.MessageContext>
Copyright © 2005-2022 Apache Software Foundation. All Rights Reserved.