public class SubscriptionManagerServiceImpl extends Object implements SubscriptionManagerService
Constructor and Description |
---|
SubscriptionManagerServiceImpl() |
Modifier and Type | Method and Description |
---|---|
void |
closeSubscription(String subscriptionID,
String destination,
String protocolType,
String destinationType)
Close subscription by subscriptionID.
|
List<Subscription> |
getAllSubscriptions()
Deprecated.
|
List<Subscription> |
getFilteredMQTTSubscriptions(MQTTSubscription subscription,
String tenantDomain)
Retrieve all matching subscriptions from andes for the given search criteria.
|
List<Subscription> |
getFilteredSubscriptions(boolean isDurable,
boolean isActive,
String protocolType,
String destinationType,
String filteredNamePattern,
boolean isFilteredNameByExactMatch,
String identifierPattern,
boolean isIdentifierPatternByExactMatch,
String ownNodeId,
int pageNumber,
int subscriptionCountPerPage)
Retrieve all matching subscriptions from andes for the given search criteria.
|
long |
getPendingMessageCount(String queueName)
Get the pending message count for the specified subscription.
|
List<Subscription> |
getSubscriptions(String isDurable,
String isActive,
String protocolType,
String destinationType)
Retrieve all matching subscriptions from andes for the given criteria.
|
int |
getTotalSubscriptionCountForSearchResult(boolean isDurable,
boolean isActive,
String protocolType,
String destinationType,
String filteredNamePattern,
boolean isFilteredNameByExactMatch,
String identiferPattern,
boolean isIdentifierPatternByExactMatch,
String ownNodeId)
Returns the total subscription count matching to a particular search criteria.
|
@Deprecated public List<Subscription> getAllSubscriptions() throws SubscriptionManagerException
getAllSubscriptions
in interface SubscriptionManagerService
SubscriptionManagerException
public List<Subscription> getSubscriptions(String isDurable, String isActive, String protocolType, String destinationType) throws SubscriptionManagerException
getSubscriptions
in interface SubscriptionManagerService
isDurable
- Retrieve durable subscriptions (can be true/false)isActive
- Retrieve active subscriptions (can be true/false/*, * meaning any)protocolType
- The protocol type of the subscriptions to retrievedestinationType
- The destination type of the subscriptions to retrieveSubscriptionManagerException
public long getPendingMessageCount(String queueName) throws SubscriptionManagerException
getPendingMessageCount
in interface SubscriptionManagerService
queueName
- for which the pending message count need to be calculatedSubscriptionManagerException
public List<Subscription> getFilteredSubscriptions(boolean isDurable, boolean isActive, String protocolType, String destinationType, String filteredNamePattern, boolean isFilteredNameByExactMatch, String identifierPattern, boolean isIdentifierPatternByExactMatch, String ownNodeId, int pageNumber, int subscriptionCountPerPage) throws SubscriptionManagerException
getFilteredSubscriptions
in interface SubscriptionManagerService
isDurable
- are the subscriptions to be retrieve durable (true/ false)isActive
- are the subscriptions to be retrieved active (true/false)protocolType
- the protocol type of the subscriptions to be retrieveddestinationType
- the destination type of the subscriptions to be retrievedfilteredNamePattern
- queue or topic name pattern to search the subscriptions ("" for all)isFilteredNameByExactMatch
- exactly match the name or notidentifierPattern
- identifier pattern to search the subscriptions ("" for all)isIdentifierPatternByExactMatch
- exactly match the identifier or notownNodeId
- node Id of the node which own the subscriptionspageNumber
- page number in the pagination tablesubscriptionCountPerPage
- number of subscriptions to be shown in the UI per pageSubscriptionManagerException
- throws when an error occurspublic List<Subscription> getFilteredMQTTSubscriptions(MQTTSubscription subscription, String tenantDomain) throws SubscriptionManagerException
getFilteredMQTTSubscriptions
in interface SubscriptionManagerService
subscription
- are the subscriptions to be retrieve durable (true/ false)tenantDomain
- are the subscriptions to be retrieve durable (true/ false)SubscriptionManagerException
- throws when an error occurspublic int getTotalSubscriptionCountForSearchResult(boolean isDurable, boolean isActive, String protocolType, String destinationType, String filteredNamePattern, boolean isFilteredNameByExactMatch, String identiferPattern, boolean isIdentifierPatternByExactMatch, String ownNodeId) throws SubscriptionManagerException
getTotalSubscriptionCountForSearchResult
in interface SubscriptionManagerService
isDurable
- are the subscriptions to be retrieve durable (true/ false)isActive
- are the subscriptions to be retrieved active (true/false)protocolType
- the protocol type of the subscriptions to be retrieveddestinationType
- the destination type of the subscriptions to be retrievedfilteredNamePattern
- queue or topic name pattern to search the subscriptions ("" for all)isFilteredNameByExactMatch
- exactly match the name or notidentiferPattern
- identifier pattern to search the subscriptions ("" for all)isIdentifierPatternByExactMatch
- exactly match the identifier or notownNodeId
- node Id of the node which own the subscriptionsSubscriptionManagerException
- throws when an error occurspublic void closeSubscription(String subscriptionID, String destination, String protocolType, String destinationType) throws SubscriptionManagerException
between server and particular subscription
closeSubscription
in interface SubscriptionManagerService
subscriptionID
- ID of the subscription to closedestination
- queue/topic name of subscribed destinationprotocolType
- The protocol type of the subscriptions to closedestinationType
- The destination type of the subscriptions to closeSubscriptionManagerException
Copyright © 2017 WSO2. All rights reserved.