public class SubscriptionManagementBeans extends Object
Constructor and Description |
---|
SubscriptionManagementBeans() |
Modifier and Type | Method and Description |
---|---|
void |
closeSubscription(String subscriptionID,
String destination,
String protocolType,
String destinationType)
This method invokes the SubscriptionManagementInformationMBean initialized by andes component to close the
subscription forcibly.
|
ArrayList<Subscription> |
getAllSubscriptions()
Deprecated.
|
ArrayList<Subscription> |
getFilteredSubscriptions(boolean isDurable,
boolean isActive,
String protocolType,
String destinationType,
String filteredNamePattern,
boolean isFilteredNameByExactMatch,
String identifierPattern,
boolean isIdentifierPatternByExactMatch,
String ownNodeId,
int pageNumber,
int subscriptionCountPerPage)
This method invokes the SubscriptionManagementInformationMBean initialized by andes component
to retrieve subscriptions matching to the given search criteria.
|
static SubscriptionManagementBeans |
getInstance() |
long |
getPendingMessageCount(String queueName)
Get the pending message count for the specified subscription.
|
ArrayList<Subscription> |
getSubscriptions(String isDurable,
String isActive,
String protocolType,
String destinationType)
This method invokes the SubscriptionManagementInformationMBean initialized by andes component
to gather information on subscriptions.
|
int |
getTotalSubscriptionCountForSearchResult(boolean isDurable,
boolean isActive,
String protocolType,
String destinationType,
String filteredNamePattern,
boolean isFilteredNameByExactMatch,
String identifierPattern,
boolean isIdentifierPatternByExactMatch,
String ownNodeId)
This method invokes the SubscriptionManagementInformationMBean initialized by andes component
to retrieve total subscription count matching to the given search criteria.
|
public static SubscriptionManagementBeans getInstance()
public ArrayList<Subscription> getSubscriptions(String isDurable, String isActive, String protocolType, String destinationType) throws SubscriptionManagerException
isDurable
- filter subscriptions for durable topicsisActive
- filter only active subscriptionsprotocolType
- The protocol type of the subscriptionsdestinationType
- The destination type of the subscriptionsSubscriptionManagerException
public long getPendingMessageCount(String queueName) throws SubscriptionManagerException
queueName
- subscription identifier for which the pending message cound need to be calculatedSubscriptionManagerException
public ArrayList<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
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 int getTotalSubscriptionCountForSearchResult(boolean isDurable, boolean isActive, String protocolType, String destinationType, String filteredNamePattern, boolean isFilteredNameByExactMatch, String identifierPattern, boolean isIdentifierPatternByExactMatch, String ownNodeId) throws SubscriptionManagerException
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 subscriptionsSubscriptionManagerException
- throws when an error occurs@Deprecated public ArrayList<Subscription> getAllSubscriptions() throws SubscriptionManagerException
SubscriptionManagerException
public void closeSubscription(String subscriptionID, String destination, String protocolType, String destinationType) throws SubscriptionManagerException
subscriptionID
- ID of the subscription to closedestination
- queue/topic name of subscribed destinationSubscriptionManagerException
Copyright © 2023 WSO2. All rights reserved.