Package | Description |
---|---|
org.wso2.carbon.andes.core | |
org.wso2.carbon.andes.core.internal.registry | |
org.wso2.carbon.andes.core.internal.util |
Modifier and Type | Method and Description |
---|---|
List<Subscription> |
SubscriptionManagerServiceImpl.getAllSubscriptions()
Deprecated.
|
List<Subscription> |
SubscriptionManagerService.getAllSubscriptions() |
List<Subscription> |
SubscriptionManagerServiceImpl.getFilteredMQTTSubscriptions(MQTTSubscription subscription,
String tenantDomain)
Retrieve all matching subscriptions from andes for the given search criteria.
|
List<Subscription> |
SubscriptionManagerService.getFilteredMQTTSubscriptions(MQTTSubscription subscription,
String tenantDomain)
Retrieve all matching subscriptions from andes for the given search criteria.
|
List<Subscription> |
SubscriptionManagerServiceImpl.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.
|
List<Subscription> |
SubscriptionManagerService.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.
|
List<Subscription> |
SubscriptionManagerServiceImpl.getSubscriptions(String isDurable,
String isActive,
String protocolType,
String destinationType)
Retrieve all matching subscriptions from andes for the given criteria.
|
List<Subscription> |
SubscriptionManagerService.getSubscriptions(String isDurable,
String isActive,
String protocolType,
String destinationType)
Retrieve all matching subscriptions from andes for the given criteria.
|
Modifier and Type | Method and Description |
---|---|
ArrayList<Subscription> |
SubscriptionManagementBeans.getAllSubscriptions()
Deprecated.
|
ArrayList<Subscription> |
SubscriptionManagementBeans.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.
|
ArrayList<Subscription> |
SubscriptionManagementBeans.getSubscriptions(String isDurable,
String isActive,
String protocolType,
String destinationType)
This method invokes the SubscriptionManagementInformationMBean initialized by andes component
to gather information on subscriptions.
|
Modifier and Type | Method and Description |
---|---|
static Subscription |
Utils.parseStringToASubscription(String subscriptionInfo)
Parsing a string to a
Subscription |
Modifier and Type | Method and Description |
---|---|
static List<Subscription> |
Utils.filterDomainSpecificSubscribers(List<Subscription> allSubscriptions)
Filters the domain specific subscriptions from a list of subscriptions
|
static List<Subscription> |
MQTTUtils.filterDomainSpecificSubscribers(List<Subscription> allSubscriptions,
String tenantDomain)
Filters the domain specific subscriptions from a list of subscriptions
|
Modifier and Type | Method and Description |
---|---|
static List<Subscription> |
Utils.filterDomainSpecificSubscribers(List<Subscription> allSubscriptions)
Filters the domain specific subscriptions from a list of subscriptions
|
static List<Subscription> |
MQTTUtils.filterDomainSpecificSubscribers(List<Subscription> allSubscriptions,
String tenantDomain)
Filters the domain specific subscriptions from a list of subscriptions
|
Copyright © 2023 WSO2. All rights reserved.