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, setPermissionUpdateTimestamp
public 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"BrokerManagerAdminException
public void deleteTopicFromRegistry(String topicName, String subscriptionId) throws BrokerManagerAdminException
topicName
- Topic NamesubscriptionId
- Subscription IDBrokerManagerAdminException
public 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 closeBrokerManagerAdminException
public 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 retrievedBrokerManagerAdminException
public 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
BrokerManagerAdminException
Copyright © 2023 WSO2. All rights reserved.