public interface AsyncClient
extends com.aliyun.core.utils.SdkAutoCloseable
static DefaultAsyncClientBuilder builder()
static AsyncClient create()
CompletableFuture<ActiveCaCertificateResponse> activeCaCertificate(ActiveCaCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of ActiveCaCertificate ActiveCaCertificateRequestCompletableFuture<ActiveDeviceCertificateResponse> activeDeviceCertificate(ActiveDeviceCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of ActiveDeviceCertificate ActiveDeviceCertificateRequestCompletableFuture<AddCustomAuthConnectBlackResponse> addCustomAuthConnectBlack(AddCustomAuthConnectBlackRequest request)
request - the request parameters of AddCustomAuthConnectBlack AddCustomAuthConnectBlackRequestCompletableFuture<AddCustomAuthIdentityResponse> addCustomAuthIdentity(AddCustomAuthIdentityRequest request)
request - the request parameters of AddCustomAuthIdentity AddCustomAuthIdentityRequestCompletableFuture<AddCustomAuthPermissionResponse> addCustomAuthPermission(AddCustomAuthPermissionRequest request)
request - the request parameters of AddCustomAuthPermission AddCustomAuthPermissionRequestCompletableFuture<ApplyTokenResponse> applyToken(ApplyTokenRequest request)
You can call this operation up to 100 times per second per account. If you want to increase the limit, join the DingTalk group 35228338 to contact ApsaraMQ for MQTT technical support.
request - the request parameters of ApplyToken ApplyTokenRequestCompletableFuture<BatchQuerySessionByClientIdsResponse> batchQuerySessionByClientIds(BatchQuerySessionByClientIdsRequest request)
You can call the BatchQuerySessionByClientIds operation up to 100 times per second. For more information, see Limits on QPS.
request - the request parameters of BatchQuerySessionByClientIds BatchQuerySessionByClientIdsRequestCompletableFuture<CloseConnectionResponse> closeConnection(CloseConnectionRequest request)
This API is still in the testing phase and is only available for Professional Edition instances in the Shanghai region. Legacy instances are not supported at this time.
request - the request parameters of CloseConnection CloseConnectionRequestCompletableFuture<CreateGroupIdResponse> createGroupId(CreateGroupIdRequest request)
Each successful call to the CreateGroupId operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of CreateGroupId CreateGroupIdRequestCompletableFuture<DeleteCaCertificateResponse> deleteCaCertificate(DeleteCaCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of DeleteCaCertificate DeleteCaCertificateRequestCompletableFuture<DeleteCustomAuthConnectBlackResponse> deleteCustomAuthConnectBlack(DeleteCustomAuthConnectBlackRequest request)
request - the request parameters of DeleteCustomAuthConnectBlack DeleteCustomAuthConnectBlackRequestCompletableFuture<DeleteCustomAuthIdentityResponse> deleteCustomAuthIdentity(DeleteCustomAuthIdentityRequest request)
request - the request parameters of DeleteCustomAuthIdentity DeleteCustomAuthIdentityRequestCompletableFuture<DeleteCustomAuthPermissionResponse> deleteCustomAuthPermission(DeleteCustomAuthPermissionRequest request)
request - the request parameters of DeleteCustomAuthPermission DeleteCustomAuthPermissionRequestCompletableFuture<DeleteDeviceCertificateResponse> deleteDeviceCertificate(DeleteDeviceCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of DeleteDeviceCertificate DeleteDeviceCertificateRequestCompletableFuture<DeleteGroupIdResponse> deleteGroupId(DeleteGroupIdRequest request)
Each successful call to the DeleteGroupId operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of DeleteGroupId DeleteGroupIdRequestCompletableFuture<DisasterDowngradeResponse> disasterDowngrade(DisasterDowngradeRequest request)
request - the request parameters of DisasterDowngrade DisasterDowngradeRequestCompletableFuture<DisasterRecoveryResponse> disasterRecovery(DisasterRecoveryRequest request)
request - the request parameters of DisasterRecovery DisasterRecoveryRequestCompletableFuture<GetCaCertificateResponse> getCaCertificate(GetCaCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of GetCaCertificate GetCaCertificateRequestCompletableFuture<GetDeviceCertificateResponse> getDeviceCertificate(GetDeviceCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of GetDeviceCertificate GetDeviceCertificateRequestCompletableFuture<GetDeviceCredentialResponse> getDeviceCredential(GetDeviceCredentialRequest request)
You can call this operation up to 500 times per second per account. If the limit is exceeded, throttling is triggered. We recommend that you take note of this limit when you call this operation. For more information, see Limits on QPS.
request - the request parameters of GetDeviceCredential GetDeviceCredentialRequestCompletableFuture<GetRegisterCodeResponse> getRegisterCode(GetRegisterCodeRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of GetRegisterCode GetRegisterCodeRequestCompletableFuture<InactivateCaCertificateResponse> inactivateCaCertificate(InactivateCaCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of InactivateCaCertificate InactivateCaCertificateRequestCompletableFuture<InactivateDeviceCertificateResponse> inactivateDeviceCertificate(InactivateDeviceCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of InactivateDeviceCertificate InactivateDeviceCertificateRequestCompletableFuture<ListCaCertificateResponse> listCaCertificate(ListCaCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of ListCaCertificate ListCaCertificateRequestCompletableFuture<ListDeviceCertificateResponse> listDeviceCertificate(ListDeviceCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of ListDeviceCertificate ListDeviceCertificateRequestCompletableFuture<ListDeviceCertificateByCaSnResponse> listDeviceCertificateByCaSn(ListDeviceCertificateByCaSnRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of ListDeviceCertificateByCaSn ListDeviceCertificateByCaSnRequestCompletableFuture<ListDeviceCredentialClientIdResponse> listDeviceCredentialClientId(ListDeviceCredentialClientIdRequest request)
request - the request parameters of ListDeviceCredentialClientId ListDeviceCredentialClientIdRequestCompletableFuture<ListGroupIdResponse> listGroupId(ListGroupIdRequest request)
Each successful call to the ListGroupId operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of ListGroupId ListGroupIdRequestCompletableFuture<ListInstancesResponse> listInstances(ListInstancesRequest request)
request - the request parameters of ListInstances ListInstancesRequestCompletableFuture<ListTagResourcesResponse> listTagResources(ListTagResourcesRequest request)
request - the request parameters of ListTagResources ListTagResourcesRequestCompletableFuture<QueryCustomAuthConnectBlackResponse> queryCustomAuthConnectBlack(QueryCustomAuthConnectBlackRequest request)
request - the request parameters of QueryCustomAuthConnectBlack QueryCustomAuthConnectBlackRequestCompletableFuture<QueryCustomAuthIdentityResponse> queryCustomAuthIdentity(QueryCustomAuthIdentityRequest request)
request - the request parameters of QueryCustomAuthIdentity QueryCustomAuthIdentityRequestCompletableFuture<QueryCustomAuthPermissionResponse> queryCustomAuthPermission(QueryCustomAuthPermissionRequest request)
request - the request parameters of QueryCustomAuthPermission QueryCustomAuthPermissionRequestCompletableFuture<QueryMqttTraceDeviceResponse> queryMqttTraceDevice(QueryMqttTraceDeviceRequest request)
Each successful call to the QueryMqttTraceDevice operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of QueryMqttTraceDevice QueryMqttTraceDeviceRequestCompletableFuture<QueryMqttTraceMessageOfClientResponse> queryMqttTraceMessageOfClient(QueryMqttTraceMessageOfClientRequest request)
Each successful call to the QueryMqttTraceMessageOfClient operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of QueryMqttTraceMessageOfClient QueryMqttTraceMessageOfClientRequestCompletableFuture<QueryMqttTraceMessagePublishResponse> queryMqttTraceMessagePublish(QueryMqttTraceMessagePublishRequest request)
Each successful call to the QueryMqttTraceMessagePublish operation increases the messaging transactions per second (TPS). This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of QueryMqttTraceMessagePublish QueryMqttTraceMessagePublishRequestCompletableFuture<QueryMqttTraceMessageSubscribeResponse> queryMqttTraceMessageSubscribe(QueryMqttTraceMessageSubscribeRequest request)
Each successful call to the QueryMqttTraceMessageSubscribe operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of QueryMqttTraceMessageSubscribe QueryMqttTraceMessageSubscribeRequestCompletableFuture<QuerySessionByClientIdResponse> querySessionByClientId(QuerySessionByClientIdRequest request)
You can call this operation up to 500 times per second.**** For more information, see Limits on QPS.
request - the request parameters of QuerySessionByClientId QuerySessionByClientIdRequestCompletableFuture<QueryTokenResponse> queryToken(QueryTokenRequest request)
You can call this operation up to 100 times per second per account. If you want to increase the limit, join the DingTalk group 35228338 to contact ApsaraMQ for MQTT technical support.
request - the request parameters of QueryToken QueryTokenRequestCompletableFuture<RefreshDeviceCredentialResponse> refreshDeviceCredential(RefreshDeviceCredentialRequest request)
You can call this operation up to 500 times per second per account. If the limit is exceeded, throttling is triggered. This may affect your business. We recommend that you take note of this limit when you call this operation. For more information, see Limits on QPS.
Each successful call to the RefreshDeviceCredential operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
request - the request parameters of RefreshDeviceCredential RefreshDeviceCredentialRequestCompletableFuture<RegisterCaCertificateResponse> registerCaCertificate(RegisterCaCertificateRequest request)
Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
request - the request parameters of RegisterCaCertificate RegisterCaCertificateRequestCompletableFuture<RegisterDeviceCredentialResponse> registerDeviceCredential(RegisterDeviceCredentialRequest request)
You can call this operation up to 500 times per second per account. If the limit is exceeded, throttling is triggered. This may affect your business. We recommend that you take note of this limit when you call this operation. For more information, see Limits on QPS.
request - the request parameters of RegisterDeviceCredential RegisterDeviceCredentialRequestCompletableFuture<RevokeTokenResponse> revokeToken(RevokeTokenRequest request)
You can call this operation up to 5 times per second per account. If you want to increase the limit, join the DingTalk group 35228338 to contact ApsaraMQ for MQTT technical support.
request - the request parameters of RevokeToken RevokeTokenRequestCompletableFuture<SendMessageResponse> sendMessage(SendMessageRequest request)
The SendMessage operation is called by an application on a cloud server. This operation is complementary to the operation that is called to send a message from an ApsaraMQ for MQTT client. For information about the differences between the scenarios of sending messages from applications on cloud servers and the scenarios of sending messages from ApsaraMQ for MQTT clients, see Developer guide.
request - the request parameters of SendMessage SendMessageRequestCompletableFuture<SetSniConfigResponse> setSniConfig(SetSniConfigRequest request)
request - the request parameters of SetSniConfig SetSniConfigRequestCompletableFuture<TagResourcesResponse> tagResources(TagResourcesRequest request)
request - the request parameters of TagResources TagResourcesRequestCompletableFuture<UnRegisterDeviceCredentialResponse> unRegisterDeviceCredential(UnRegisterDeviceCredentialRequest request)
You can call this operation up to 500 times per second per account. If the limit is exceeded, throttling is triggered. This may affect your business. We recommend that you take note of this limit when you call this operation. For more information, see Limits on QPS.
request - the request parameters of UnRegisterDeviceCredential UnRegisterDeviceCredentialRequestCompletableFuture<UntagResourcesResponse> untagResources(UntagResourcesRequest request)
request - the request parameters of UntagResources UntagResourcesRequestCompletableFuture<UpdateCustomAuthIdentityResponse> updateCustomAuthIdentity(UpdateCustomAuthIdentityRequest request)
request - the request parameters of UpdateCustomAuthIdentity UpdateCustomAuthIdentityRequestCompletableFuture<UpdateCustomAuthPermissionResponse> updateCustomAuthPermission(UpdateCustomAuthPermissionRequest request)
request - the request parameters of UpdateCustomAuthPermission UpdateCustomAuthPermissionRequestCopyright © 2025. All rights reserved.