public class AndesMQTTAdminServiceStub extends org.apache.axis2.client.Stub implements AndesMQTTAdminService
Modifier and Type | Field and Description |
---|---|
protected org.apache.axis2.description.AxisOperation[] |
_operations |
Constructor and Description |
---|
AndesMQTTAdminServiceStub()
Default Constructor
|
AndesMQTTAdminServiceStub(org.apache.axis2.context.ConfigurationContext configurationContext)
Default Constructor
|
AndesMQTTAdminServiceStub(org.apache.axis2.context.ConfigurationContext configurationContext,
String targetEndpoint)
Constructor that takes in a configContext
|
AndesMQTTAdminServiceStub(org.apache.axis2.context.ConfigurationContext configurationContext,
String targetEndpoint,
boolean useSeparateListener)
Constructor that takes in a configContext and useseperate listner
|
AndesMQTTAdminServiceStub(String targetEndpoint)
Constructor taking the target endpoint
|
Modifier and Type | Method and Description |
---|---|
boolean |
checkCurrentUserHasTopicSubscriptionClosePermission()
Auto generated method signature
|
void |
closeSubscription(String subscriptionID84,
String destination85,
String protocolType86,
String destinationType87)
Auto generated method signature
|
void |
deleteTopicFromRegistry(String topicName55,
String subscriptionId56)
Auto generated method signature
|
Subscription[] |
getFilteredSubscriptions(MQTTSubscription subscription79,
String tenantDomain80)
Auto generated method signature
|
long |
getMessageCount(String destinationName74,
String msgPattern75)
Auto generated method signature
|
Subscription[] |
getSubscriptions(String isDurable90,
String isActive91,
String protocolType92,
String destinationType93)
Auto generated method signature
|
int |
getTotalSubscriptionCountForSearchResult(boolean isDurable62,
boolean isActive63,
String protocolType64,
String destinationType65,
String filteredNamePattern66,
boolean isFilteredNameByExactMatch67,
String identifierPattern68,
boolean isIdentifierPatternByExactMatch69,
String ownNodeId70)
Auto generated method signature
|
void |
startcheckCurrentUserHasTopicSubscriptionClosePermission(AndesMQTTAdminServiceCallbackHandler callback)
Auto generated method signature for Asynchronous Invocations
|
void |
startcloseSubscription(String subscriptionID84,
String destination85,
String protocolType86,
String destinationType87,
AndesMQTTAdminServiceCallbackHandler callback)
Auto generated method signature for Asynchronous Invocations
|
void |
startdeleteTopicFromRegistry(String topicName55,
String subscriptionId56,
AndesMQTTAdminServiceCallbackHandler callback)
Auto generated method signature for Asynchronous Invocations
|
void |
startgetFilteredSubscriptions(MQTTSubscription subscription79,
String tenantDomain80,
AndesMQTTAdminServiceCallbackHandler callback)
Auto generated method signature for Asynchronous Invocations
|
void |
startgetMessageCount(String destinationName74,
String msgPattern75,
AndesMQTTAdminServiceCallbackHandler callback)
Auto generated method signature for Asynchronous Invocations
|
void |
startgetSubscriptions(String isDurable90,
String isActive91,
String protocolType92,
String destinationType93,
AndesMQTTAdminServiceCallbackHandler callback)
Auto generated method signature for Asynchronous Invocations
|
void |
startgetTotalSubscriptionCountForSearchResult(boolean isDurable62,
boolean isActive63,
String protocolType64,
String destinationType65,
String filteredNamePattern66,
boolean isFilteredNameByExactMatch67,
String identifierPattern68,
boolean isIdentifierPatternByExactMatch69,
String ownNodeId70,
AndesMQTTAdminServiceCallbackHandler callback)
Auto generated method signature for Asynchronous Invocations
|
_getServiceClient, _setServiceClient, addAnonymousOperations, addHeader, addHeader, addHttpHeader, addPropertyToOperationClient, addPropertyToOperationClient, addPropertyToOperationClient, cleanup, createEnvelope, finalize, getFactory, setMustUnderstand, setServiceClientEPR
public AndesMQTTAdminServiceStub(org.apache.axis2.context.ConfigurationContext configurationContext, String targetEndpoint) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public AndesMQTTAdminServiceStub(org.apache.axis2.context.ConfigurationContext configurationContext, String targetEndpoint, boolean useSeparateListener) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public AndesMQTTAdminServiceStub(org.apache.axis2.context.ConfigurationContext configurationContext) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public AndesMQTTAdminServiceStub() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public AndesMQTTAdminServiceStub(String targetEndpoint) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void deleteTopicFromRegistry(String topicName55, String subscriptionId56) throws RemoteException, AndesMQTTAdminServiceBrokerManagerAdminException
deleteTopicFromRegistry
in interface AndesMQTTAdminService
deleteTopicFromRegistry54
- AndesMQTTAdminServiceBrokerManagerAdminException
- :RemoteException
AndesMQTTAdminService.deleteTopicFromRegistry(java.lang.String, java.lang.String)
public void startdeleteTopicFromRegistry(String topicName55, String subscriptionId56, AndesMQTTAdminServiceCallbackHandler callback) throws RemoteException
startdeleteTopicFromRegistry
in interface AndesMQTTAdminService
deleteTopicFromRegistry54
- RemoteException
AndesMQTTAdminService.startdeleteTopicFromRegistry(java.lang.String, java.lang.String, org.wso2.carbon.andes.mqtt.stub.AndesMQTTAdminServiceCallbackHandler)
public boolean checkCurrentUserHasTopicSubscriptionClosePermission() throws RemoteException, AndesMQTTAdminServiceBrokerManagerAdminException
checkCurrentUserHasTopicSubscriptionClosePermission
in interface AndesMQTTAdminService
checkCurrentUserHasTopicSubscriptionClosePermission58
- AndesMQTTAdminServiceBrokerManagerAdminException
- :RemoteException
AndesMQTTAdminService.checkCurrentUserHasTopicSubscriptionClosePermission()
public void startcheckCurrentUserHasTopicSubscriptionClosePermission(AndesMQTTAdminServiceCallbackHandler callback) throws RemoteException
startcheckCurrentUserHasTopicSubscriptionClosePermission
in interface AndesMQTTAdminService
checkCurrentUserHasTopicSubscriptionClosePermission58
- RemoteException
AndesMQTTAdminService.startcheckCurrentUserHasTopicSubscriptionClosePermission(org.wso2.carbon.andes.mqtt.stub.AndesMQTTAdminServiceCallbackHandler)
public int getTotalSubscriptionCountForSearchResult(boolean isDurable62, boolean isActive63, String protocolType64, String destinationType65, String filteredNamePattern66, boolean isFilteredNameByExactMatch67, String identifierPattern68, boolean isIdentifierPatternByExactMatch69, String ownNodeId70) throws RemoteException, AndesMQTTAdminServiceBrokerManagerAdminException
getTotalSubscriptionCountForSearchResult
in interface AndesMQTTAdminService
getTotalSubscriptionCountForSearchResult61
- AndesMQTTAdminServiceBrokerManagerAdminException
- :RemoteException
AndesMQTTAdminService.getTotalSubscriptionCountForSearchResult(boolean, boolean, java.lang.String, java.lang.String, java.lang.String, boolean, java.lang.String, boolean, java.lang.String)
public void startgetTotalSubscriptionCountForSearchResult(boolean isDurable62, boolean isActive63, String protocolType64, String destinationType65, String filteredNamePattern66, boolean isFilteredNameByExactMatch67, String identifierPattern68, boolean isIdentifierPatternByExactMatch69, String ownNodeId70, AndesMQTTAdminServiceCallbackHandler callback) throws RemoteException
startgetTotalSubscriptionCountForSearchResult
in interface AndesMQTTAdminService
getTotalSubscriptionCountForSearchResult61
- RemoteException
AndesMQTTAdminService.startgetTotalSubscriptionCountForSearchResult(boolean, boolean, java.lang.String, java.lang.String, java.lang.String, boolean, java.lang.String, boolean, java.lang.String, org.wso2.carbon.andes.mqtt.stub.AndesMQTTAdminServiceCallbackHandler)
public long getMessageCount(String destinationName74, String msgPattern75) throws RemoteException, AndesMQTTAdminServiceBrokerManagerAdminException
getMessageCount
in interface AndesMQTTAdminService
getMessageCount73
- AndesMQTTAdminServiceBrokerManagerAdminException
- :RemoteException
AndesMQTTAdminService.getMessageCount(java.lang.String, java.lang.String)
public void startgetMessageCount(String destinationName74, String msgPattern75, AndesMQTTAdminServiceCallbackHandler callback) throws RemoteException
startgetMessageCount
in interface AndesMQTTAdminService
getMessageCount73
- RemoteException
AndesMQTTAdminService.startgetMessageCount(java.lang.String, java.lang.String, org.wso2.carbon.andes.mqtt.stub.AndesMQTTAdminServiceCallbackHandler)
public Subscription[] getFilteredSubscriptions(MQTTSubscription subscription79, String tenantDomain80) throws RemoteException, AndesMQTTAdminServiceBrokerManagerAdminException
getFilteredSubscriptions
in interface AndesMQTTAdminService
getFilteredSubscriptions78
- AndesMQTTAdminServiceBrokerManagerAdminException
- :RemoteException
AndesMQTTAdminService.getFilteredSubscriptions(org.wso2.carbon.andes.core.types.xsd.MQTTSubscription, java.lang.String)
public void startgetFilteredSubscriptions(MQTTSubscription subscription79, String tenantDomain80, AndesMQTTAdminServiceCallbackHandler callback) throws RemoteException
startgetFilteredSubscriptions
in interface AndesMQTTAdminService
getFilteredSubscriptions78
- RemoteException
AndesMQTTAdminService.startgetFilteredSubscriptions(org.wso2.carbon.andes.core.types.xsd.MQTTSubscription, java.lang.String, org.wso2.carbon.andes.mqtt.stub.AndesMQTTAdminServiceCallbackHandler)
public void closeSubscription(String subscriptionID84, String destination85, String protocolType86, String destinationType87) throws RemoteException, AndesMQTTAdminServiceBrokerManagerAdminException
closeSubscription
in interface AndesMQTTAdminService
closeSubscription83
- AndesMQTTAdminServiceBrokerManagerAdminException
- :RemoteException
AndesMQTTAdminService.closeSubscription(java.lang.String, java.lang.String, java.lang.String, java.lang.String)
public void startcloseSubscription(String subscriptionID84, String destination85, String protocolType86, String destinationType87, AndesMQTTAdminServiceCallbackHandler callback) throws RemoteException
startcloseSubscription
in interface AndesMQTTAdminService
closeSubscription83
- RemoteException
AndesMQTTAdminService.startcloseSubscription(java.lang.String, java.lang.String, java.lang.String, java.lang.String, org.wso2.carbon.andes.mqtt.stub.AndesMQTTAdminServiceCallbackHandler)
public Subscription[] getSubscriptions(String isDurable90, String isActive91, String protocolType92, String destinationType93) throws RemoteException, AndesMQTTAdminServiceBrokerManagerAdminException
getSubscriptions
in interface AndesMQTTAdminService
getSubscriptions89
- AndesMQTTAdminServiceBrokerManagerAdminException
- :RemoteException
AndesMQTTAdminService.getSubscriptions(java.lang.String, java.lang.String, java.lang.String, java.lang.String)
public void startgetSubscriptions(String isDurable90, String isActive91, String protocolType92, String destinationType93, AndesMQTTAdminServiceCallbackHandler callback) throws RemoteException
startgetSubscriptions
in interface AndesMQTTAdminService
getSubscriptions89
- RemoteException
AndesMQTTAdminService.startgetSubscriptions(java.lang.String, java.lang.String, java.lang.String, java.lang.String, org.wso2.carbon.andes.mqtt.stub.AndesMQTTAdminServiceCallbackHandler)
Copyright © 2019 WSO2. All rights reserved.