public class AndesMQTTAdminService
extends org.wso2.carbon.core.AbstractAdmin
| Modifier and Type | Class and Description |
|---|---|
class |
AndesMQTTAdminService.CustomSubscriptionComparator
A comparator class to order subscriptions.
|
| Constructor and Description |
|---|
AndesMQTTAdminService() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
checkCurrentUserHasTopicSubscriptionClosePermission()
Evaluate current logged in user has close subscription permission for topic subscriptions.
|
void |
closeSubscription(String subscriptionID,
String destination,
String protocolType,
String destinationType)
Close subscription defined by subscription ID forcibly
|
void |
deleteTopicFromRegistry(String topicName,
String subscriptionId)
Delete topic related resources from registry
|
org.wso2.carbon.andes.core.types.Subscription[] |
getFilteredSubscriptions(org.wso2.carbon.andes.core.types.MQTTSubscription subscription,
String tenantDomain)
Retrieve subscriptions matching to the given search criteria.
|
long |
getMessageCount(String destinationName,
String msgPattern)
Gets the message count for a queue
|
org.wso2.carbon.andes.core.types.Subscription[] |
getSubscriptions(String isDurable,
String isActive,
String protocolType,
String destinationType)
Retrieve subscriptions matching the given criteria.
|
int |
getTotalSubscriptionCountForSearchResult(org.wso2.carbon.andes.core.types.MQTTSubscription subscription)
Returns the total subscription count relevant to a particular search criteria.
|
getAxisConfig, getConfigContext, getConfigSystemRegistry, getConfigUserRegistry, getGovernanceRegistry, getGovernanceSystemRegistry, getGovernanceUserRegistry, getHttpSession, getLocalRepo, getRegistry, getTenantDomain, getUsername, getUserRealm, setConfigurationContext, setPermissionUpdateTimestamppublic long getMessageCount(String destinationName, String msgPattern) throws BrokerManagerAdminException
destinationName - the destination name. the name of the queue or topic.msgPattern - The exchange type used to transfer messages with the given destinationName.
e.g. "queue" or "topic"BrokerManagerAdminExceptionpublic void deleteTopicFromRegistry(String topicName, String subscriptionId) throws BrokerManagerAdminException
topicName - Topic NamesubscriptionId - Subscription IDBrokerManagerAdminExceptionpublic void closeSubscription(String subscriptionID, String destination, String protocolType, String destinationType) throws BrokerManagerAdminException
subscriptionID - ID of the subscriptiondestination - queue / topic name of the subscribed destinationprotocolType - The protocol type of the subscriptions to closedestinationType - The destination type of the subscriptions to closeBrokerManagerAdminExceptionpublic org.wso2.carbon.andes.core.types.Subscription[] getSubscriptions(String isDurable, String isActive, String protocolType, String destinationType) throws BrokerManagerAdminException
isDurable - Are the subscriptions to be retrieved durable (true/false)isActive - Are the subscriptions to be retrieved active (true/false/*, * meaning any)protocolType - The protocol type of the subscriptions to be retrieveddestinationType - The destination type of the subscriptions to be retrievedBrokerManagerAdminExceptionpublic org.wso2.carbon.andes.core.types.Subscription[] getFilteredSubscriptions(org.wso2.carbon.andes.core.types.MQTTSubscription subscription,
String tenantDomain)
throws BrokerManagerAdminException
subscription - is the the details of subscription objecttenantDomain - is the Domain of a particular tenantBrokerManagerAdminException - throws when an error occurspublic int getTotalSubscriptionCountForSearchResult(org.wso2.carbon.andes.core.types.MQTTSubscription subscription)
throws BrokerManagerAdminException
subscription - is the the details of subscription objectBrokerManagerAdminException - hrows when an error occurspublic boolean checkCurrentUserHasTopicSubscriptionClosePermission()
throws BrokerManagerAdminException
BrokerManagerAdminExceptionCopyright © 2018 WSO2. All rights reserved.