DefaultAsyncClient (alibabacloud-onsmqtt20200420 1.0.8 API)

java.lang.Object
- com.aliyun.sdk.service.onsmqtt20200420.DefaultAsyncClient

所有已实现的接口:

com.aliyun.core.utils.SdkAutoCloseable, AsyncClient, AutoCloseable
```
public final class DefaultAsyncClient
extends Object
implements AsyncClient
```
Main client.

字段概要

字段
限定符和类型	字段和说明
`protected Map<String,String>`	`endpointMap`
`protected String`	`endpointRule`
`protected darabonba.core.TeaAsyncHandler`	`handler`
`protected String`	`product`
`protected darabonba.core.TeaRequest`	`REQUEST`
`protected String`	`version`

构造器概要

构造器
限定符构造器和说明

protected DefaultAsyncClient(darabonba.core.client.ClientConfiguration configuration)

构造器
限定符	构造器和说明
`protected`	`DefaultAsyncClient(darabonba.core.client.ClientConfiguration configuration)`

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`CompletableFuture<ActiveCaCertificateResponse>`	`activeCaCertificate(ActiveCaCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<ActiveDeviceCertificateResponse>`	`activeDeviceCertificate(ActiveDeviceCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<AddCustomAuthConnectBlackResponse>`	`addCustomAuthConnectBlack(AddCustomAuthConnectBlackRequest request)`
`CompletableFuture<AddCustomAuthIdentityResponse>`	`addCustomAuthIdentity(AddCustomAuthIdentityRequest request)`
`CompletableFuture<AddCustomAuthPermissionResponse>`	`addCustomAuthPermission(AddCustomAuthPermissionRequest request)`
`CompletableFuture<ApplyTokenResponse>`	`applyToken(ApplyTokenRequest request)` description : You can call this operation up to 100 times per second per account.
`CompletableFuture<BatchQuerySessionByClientIdsResponse>`	`batchQuerySessionByClientIds(BatchQuerySessionByClientIdsRequest request)` description : You can call the BatchQuerySessionByClientIds operation up to 100 times per second.
`void`	`close()`
`CompletableFuture<CloseConnectionResponse>`	`closeConnection(CloseConnectionRequest request)` description : This API is still in the testing phase and is only available for Professional Edition instances in the Shanghai region.
`CompletableFuture<CreateGroupIdResponse>`	`createGroupId(CreateGroupIdRequest request)` description : Each successful call to the CreateGroupId operation increases the messaging transactions per second (TPS) by one.
`CompletableFuture<DeleteCaCertificateResponse>`	`deleteCaCertificate(DeleteCaCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<DeleteCustomAuthConnectBlackResponse>`	`deleteCustomAuthConnectBlack(DeleteCustomAuthConnectBlackRequest request)`
`CompletableFuture<DeleteCustomAuthIdentityResponse>`	`deleteCustomAuthIdentity(DeleteCustomAuthIdentityRequest request)`
`CompletableFuture<DeleteCustomAuthPermissionResponse>`	`deleteCustomAuthPermission(DeleteCustomAuthPermissionRequest request)`
`CompletableFuture<DeleteDeviceCertificateResponse>`	`deleteDeviceCertificate(DeleteDeviceCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<DeleteGroupIdResponse>`	`deleteGroupId(DeleteGroupIdRequest request)` description : Each successful call to the DeleteGroupId operation increases the messaging transactions per second (TPS) by one.
`CompletableFuture<DisasterDowngradeResponse>`	`disasterDowngrade(DisasterDowngradeRequest request)`
`CompletableFuture<DisasterRecoveryResponse>`	`disasterRecovery(DisasterRecoveryRequest request)`
`CompletableFuture<GetCaCertificateResponse>`	`getCaCertificate(GetCaCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<GetDeviceCertificateResponse>`	`getDeviceCertificate(GetDeviceCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<GetDeviceCredentialResponse>`	`getDeviceCredential(GetDeviceCredentialRequest request)` description : You can call this operation up to 500 times per second per account.
`CompletableFuture<GetRegisterCodeResponse>`	`getRegisterCode(GetRegisterCodeRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<InactivateCaCertificateResponse>`	`inactivateCaCertificate(InactivateCaCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<InactivateDeviceCertificateResponse>`	`inactivateDeviceCertificate(InactivateDeviceCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<ListCaCertificateResponse>`	`listCaCertificate(ListCaCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<ListDeviceCertificateResponse>`	`listDeviceCertificate(ListDeviceCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<ListDeviceCertificateByCaSnResponse>`	`listDeviceCertificateByCaSn(ListDeviceCertificateByCaSnRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<ListDeviceCredentialClientIdResponse>`	`listDeviceCredentialClientId(ListDeviceCredentialClientIdRequest request)`
`CompletableFuture<ListGroupIdResponse>`	`listGroupId(ListGroupIdRequest request)` description : Each successful call to the ListGroupId operation increases the messaging transactions per second (TPS) by one.
`CompletableFuture<ListInstancesResponse>`	`listInstances(ListInstancesRequest request)`
`CompletableFuture<ListTagResourcesResponse>`	`listTagResources(ListTagResourcesRequest request)`
`CompletableFuture<QueryCustomAuthConnectBlackResponse>`	`queryCustomAuthConnectBlack(QueryCustomAuthConnectBlackRequest request)`
`CompletableFuture<QueryCustomAuthIdentityResponse>`	`queryCustomAuthIdentity(QueryCustomAuthIdentityRequest request)`
`CompletableFuture<QueryCustomAuthPermissionResponse>`	`queryCustomAuthPermission(QueryCustomAuthPermissionRequest request)`
`CompletableFuture<QueryMqttTraceDeviceResponse>`	`queryMqttTraceDevice(QueryMqttTraceDeviceRequest request)` description : Each successful call to the QueryMqttTraceDevice operation increases the messaging transactions per second (TPS) by one.
`CompletableFuture<QueryMqttTraceMessageOfClientResponse>`	`queryMqttTraceMessageOfClient(QueryMqttTraceMessageOfClientRequest request)` description : Each successful call to the QueryMqttTraceMessageOfClient operation increases the messaging transactions per second (TPS) by one.
`CompletableFuture<QueryMqttTraceMessagePublishResponse>`	`queryMqttTraceMessagePublish(QueryMqttTraceMessagePublishRequest request)` description : Each successful call to the QueryMqttTraceMessagePublish operation increases the messaging transactions per second (TPS).
`CompletableFuture<QueryMqttTraceMessageSubscribeResponse>`	`queryMqttTraceMessageSubscribe(QueryMqttTraceMessageSubscribeRequest request)` description : Each successful call to the QueryMqttTraceMessageSubscribe operation increases the messaging transactions per second (TPS) by one.
`CompletableFuture<QuerySessionByClientIdResponse>`	`querySessionByClientId(QuerySessionByClientIdRequest request)` description : You can call this operation up to 500 times per second.**** For more information, see Limits on QPS.
`CompletableFuture<QueryTokenResponse>`	`queryToken(QueryTokenRequest request)` description : You can call this operation up to 100 times per second per account.
`CompletableFuture<RefreshDeviceCredentialResponse>`	`refreshDeviceCredential(RefreshDeviceCredentialRequest request)` description : Limits You can call this operation up to 500 times per second per account.
`CompletableFuture<RegisterCaCertificateResponse>`	`registerCaCertificate(RegisterCaCertificateRequest request)` description : Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
`CompletableFuture<RegisterDeviceCredentialResponse>`	`registerDeviceCredential(RegisterDeviceCredentialRequest request)` description : You can call this operation up to 500 times per second per account.
`CompletableFuture<RevokeTokenResponse>`	`revokeToken(RevokeTokenRequest request)` description : You can call this operation up to 5 times per second per account.
`CompletableFuture<SendMessageResponse>`	`sendMessage(SendMessageRequest request)` description : The SendMessage operation is called by an application on a cloud server.
`CompletableFuture<SetSniConfigResponse>`	`setSniConfig(SetSniConfigRequest request)`
`CompletableFuture<TagResourcesResponse>`	`tagResources(TagResourcesRequest request)`
`CompletableFuture<UnRegisterDeviceCredentialResponse>`	`unRegisterDeviceCredential(UnRegisterDeviceCredentialRequest request)` description : You can call this operation up to 500 times per second per account.
`CompletableFuture<UntagResourcesResponse>`	`untagResources(UntagResourcesRequest request)`
`CompletableFuture<UpdateCustomAuthIdentityResponse>`	`updateCustomAuthIdentity(UpdateCustomAuthIdentityRequest request)`
`CompletableFuture<UpdateCustomAuthPermissionResponse>`	`updateCustomAuthPermission(UpdateCustomAuthPermissionRequest request)`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.aliyun.sdk.service.onsmqtt20200420.AsyncClient
builder, create

- 字段详细资料
  - product
```
protected final String product
```
  - version
```
protected final String version
```
  - endpointRule
```
protected final String endpointRule
```
  - endpointMap
```
protected final Map<String,String> endpointMap
```
  - REQUEST
```
protected final darabonba.core.TeaRequest REQUEST
```
  - handler
```
protected final darabonba.core.TeaAsyncHandler handler
```
- 构造器详细资料
  - DefaultAsyncClient
```
protected DefaultAsyncClient(darabonba.core.client.ClientConfiguration configuration)
```
- 方法详细资料
  - close
```
public void close()
```
    指定者:
    
    close 在接口中 com.aliyun.core.utils.SdkAutoCloseable
    
    指定者:
    
    close 在接口中 AutoCloseable
  - activeCaCertificate
```
public CompletableFuture<ActiveCaCertificateResponse> activeCaCertificate(ActiveCaCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    - You can call this operation to reactivate only CA certificates that are registered with ApsaraMQ for MQTT brokers. You can call the ListCaCertificate operation to query CA certificates that are registered with an ApsaraMQ for MQTT instance.
    指定者:
    
    activeCaCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ActiveCaCertificate ActiveCaCertificateRequest
    
    返回:
    
    ActiveCaCertificateResponse
  - activeDeviceCertificate
```
public CompletableFuture<ActiveDeviceCertificateResponse> activeDeviceCertificate(ActiveDeviceCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    activeDeviceCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ActiveDeviceCertificate ActiveDeviceCertificateRequest
    
    返回:
    
    ActiveDeviceCertificateResponse
  - addCustomAuthConnectBlack
```
public CompletableFuture<AddCustomAuthConnectBlackResponse> addCustomAuthConnectBlack(AddCustomAuthConnectBlackRequest request)
```
    指定者:
    
    addCustomAuthConnectBlack 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of AddCustomAuthConnectBlack AddCustomAuthConnectBlackRequest
    
    返回:
    
    AddCustomAuthConnectBlackResponse
  - addCustomAuthIdentity
```
public CompletableFuture<AddCustomAuthIdentityResponse> addCustomAuthIdentity(AddCustomAuthIdentityRequest request)
```
    指定者:
    
    addCustomAuthIdentity 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of AddCustomAuthIdentity AddCustomAuthIdentityRequest
    
    返回:
    
    AddCustomAuthIdentityResponse
  - addCustomAuthPermission
```
public CompletableFuture<AddCustomAuthPermissionResponse> addCustomAuthPermission(AddCustomAuthPermissionRequest request)
```
    指定者:
    
    addCustomAuthPermission 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of AddCustomAuthPermission AddCustomAuthPermissionRequest
    
    返回:
    
    AddCustomAuthPermissionResponse
  - applyToken
```
public CompletableFuture<ApplyTokenResponse> applyToken(ApplyTokenRequest request)
```
    description :
    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.
    - Each successful call to the ApplyToken operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    applyToken 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ApplyToken ApplyTokenRequest
    
    返回:
    
    ApplyTokenResponse
  - batchQuerySessionByClientIds
```
public CompletableFuture<BatchQuerySessionByClientIdsResponse> batchQuerySessionByClientIds(BatchQuerySessionByClientIdsRequest request)
```
    description :
    You can call the BatchQuerySessionByClientIds operation up to 100 times per second. For more information, see Limits on QPS.
    - You can call the BatchQuerySessionByClientIds operation to query the status of up to 10 ApsaraMQ for MQTT clients in a single query.
    - Each successful call to the BatchQuerySessionByClientIds operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    batchQuerySessionByClientIds 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of BatchQuerySessionByClientIds BatchQuerySessionByClientIdsRequest
    
    返回:
    
    BatchQuerySessionByClientIdsResponse
  - closeConnection
```
public CompletableFuture<CloseConnectionResponse> closeConnection(CloseConnectionRequest request)
```
    description :
    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.
    
    指定者:
    
    closeConnection 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of CloseConnection CloseConnectionRequest
    
    返回:
    
    CloseConnectionResponse
  - createGroupId
```
public CompletableFuture<CreateGroupIdResponse> createGroupId(CreateGroupIdRequest request)
```
    description :
    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.
    
    指定者:
    
    createGroupId 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of CreateGroupId CreateGroupIdRequest
    
    返回:
    
    CreateGroupIdResponse
  - deleteCaCertificate
```
public CompletableFuture<DeleteCaCertificateResponse> deleteCaCertificate(DeleteCaCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    - You can call this operation to delete only CA certificates that are registered with ApsaraMQ for MQTT brokers. You can call the ListCaCertificate operation to query CA certificates that are registered with an ApsaraMQ for MQTT instance.
    - If you delete a specific CA certificate from an ApsaraMQ for MQTT broker, all device certificates that are issued by the CA certificate and are registered with the ApsaraMQ for MQTT broker are automatically deleted.
    指定者:
    
    deleteCaCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DeleteCaCertificate DeleteCaCertificateRequest
    
    返回:
    
    DeleteCaCertificateResponse
  - deleteCustomAuthConnectBlack
```
public CompletableFuture<DeleteCustomAuthConnectBlackResponse> deleteCustomAuthConnectBlack(DeleteCustomAuthConnectBlackRequest request)
```
    指定者:
    
    deleteCustomAuthConnectBlack 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DeleteCustomAuthConnectBlack DeleteCustomAuthConnectBlackRequest
    
    返回:
    
    DeleteCustomAuthConnectBlackResponse
  - deleteCustomAuthIdentity
```
public CompletableFuture<DeleteCustomAuthIdentityResponse> deleteCustomAuthIdentity(DeleteCustomAuthIdentityRequest request)
```
    指定者:
    
    deleteCustomAuthIdentity 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DeleteCustomAuthIdentity DeleteCustomAuthIdentityRequest
    
    返回:
    
    DeleteCustomAuthIdentityResponse
  - deleteCustomAuthPermission
```
public CompletableFuture<DeleteCustomAuthPermissionResponse> deleteCustomAuthPermission(DeleteCustomAuthPermissionRequest request)
```
    指定者:
    
    deleteCustomAuthPermission 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DeleteCustomAuthPermission DeleteCustomAuthPermissionRequest
    
    返回:
    
    DeleteCustomAuthPermissionResponse
  - deleteDeviceCertificate
```
public CompletableFuture<DeleteDeviceCertificateResponse> deleteDeviceCertificate(DeleteDeviceCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    deleteDeviceCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DeleteDeviceCertificate DeleteDeviceCertificateRequest
    
    返回:
    
    DeleteDeviceCertificateResponse
  - deleteGroupId
```
public CompletableFuture<DeleteGroupIdResponse> deleteGroupId(DeleteGroupIdRequest request)
```
    description :
    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.
    
    指定者:
    
    deleteGroupId 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DeleteGroupId DeleteGroupIdRequest
    
    返回:
    
    DeleteGroupIdResponse
  - disasterDowngrade
```
public CompletableFuture<DisasterDowngradeResponse> disasterDowngrade(DisasterDowngradeRequest request)
```
    指定者:
    
    disasterDowngrade 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DisasterDowngrade DisasterDowngradeRequest
    
    返回:
    
    DisasterDowngradeResponse
  - disasterRecovery
```
public CompletableFuture<DisasterRecoveryResponse> disasterRecovery(DisasterRecoveryRequest request)
```
    指定者:
    
    disasterRecovery 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of DisasterRecovery DisasterRecoveryRequest
    
    返回:
    
    DisasterRecoveryResponse
  - getCaCertificate
```
public CompletableFuture<GetCaCertificateResponse> getCaCertificate(GetCaCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    getCaCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of GetCaCertificate GetCaCertificateRequest
    
    返回:
    
    GetCaCertificateResponse
  - getDeviceCertificate
```
public CompletableFuture<GetDeviceCertificateResponse> getDeviceCertificate(GetDeviceCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    getDeviceCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of GetDeviceCertificate GetDeviceCertificateRequest
    
    返回:
    
    GetDeviceCertificateResponse
  - getDeviceCredential
```
public CompletableFuture<GetDeviceCredentialResponse> getDeviceCredential(GetDeviceCredentialRequest request)
```
    description :
    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.
    - Each successful call to the GetDeviceCredential operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    getDeviceCredential 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of GetDeviceCredential GetDeviceCredentialRequest
    
    返回:
    
    GetDeviceCredentialResponse
  - getRegisterCode
```
public CompletableFuture<GetRegisterCodeResponse> getRegisterCode(GetRegisterCodeRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    getRegisterCode 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of GetRegisterCode GetRegisterCodeRequest
    
    返回:
    
    GetRegisterCodeResponse
  - inactivateCaCertificate
```
public CompletableFuture<InactivateCaCertificateResponse> inactivateCaCertificate(InactivateCaCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    - You can call this operation to deregister only CA certificates that are registered with ApsaraMQ for MQTT brokers. You can call the ListCaCertificate operation to query CA certificates that are registered with an ApsaraMQ for MQTT instance.
    指定者:
    
    inactivateCaCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of InactivateCaCertificate InactivateCaCertificateRequest
    
    返回:
    
    InactivateCaCertificateResponse
  - inactivateDeviceCertificate
```
public CompletableFuture<InactivateDeviceCertificateResponse> inactivateDeviceCertificate(InactivateDeviceCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    inactivateDeviceCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of InactivateDeviceCertificate InactivateDeviceCertificateRequest
    
    返回:
    
    InactivateDeviceCertificateResponse
  - listCaCertificate
```
public CompletableFuture<ListCaCertificateResponse> listCaCertificate(ListCaCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    listCaCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ListCaCertificate ListCaCertificateRequest
    
    返回:
    
    ListCaCertificateResponse
  - listDeviceCertificate
```
public CompletableFuture<ListDeviceCertificateResponse> listDeviceCertificate(ListDeviceCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    listDeviceCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ListDeviceCertificate ListDeviceCertificateRequest
    
    返回:
    
    ListDeviceCertificateResponse
  - listDeviceCertificateByCaSn
```
public CompletableFuture<ListDeviceCertificateByCaSnResponse> listDeviceCertificateByCaSn(ListDeviceCertificateByCaSnRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    listDeviceCertificateByCaSn 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ListDeviceCertificateByCaSn ListDeviceCertificateByCaSnRequest
    
    返回:
    
    ListDeviceCertificateByCaSnResponse
  - listDeviceCredentialClientId
```
public CompletableFuture<ListDeviceCredentialClientIdResponse> listDeviceCredentialClientId(ListDeviceCredentialClientIdRequest request)
```
    指定者:
    
    listDeviceCredentialClientId 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ListDeviceCredentialClientId ListDeviceCredentialClientIdRequest
    
    返回:
    
    ListDeviceCredentialClientIdResponse
  - listGroupId
```
public CompletableFuture<ListGroupIdResponse> listGroupId(ListGroupIdRequest request)
```
    description :
    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.
    
    指定者:
    
    listGroupId 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ListGroupId ListGroupIdRequest
    
    返回:
    
    ListGroupIdResponse
  - listInstances
```
public CompletableFuture<ListInstancesResponse> listInstances(ListInstancesRequest request)
```
    指定者:
    
    listInstances 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ListInstances ListInstancesRequest
    
    返回:
    
    ListInstancesResponse
  - listTagResources
```
public CompletableFuture<ListTagResourcesResponse> listTagResources(ListTagResourcesRequest request)
```
    指定者:
    
    listTagResources 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of ListTagResources ListTagResourcesRequest
    
    返回:
    
    ListTagResourcesResponse
  - queryCustomAuthConnectBlack
```
public CompletableFuture<QueryCustomAuthConnectBlackResponse> queryCustomAuthConnectBlack(QueryCustomAuthConnectBlackRequest request)
```
    指定者:
    
    queryCustomAuthConnectBlack 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryCustomAuthConnectBlack QueryCustomAuthConnectBlackRequest
    
    返回:
    
    QueryCustomAuthConnectBlackResponse
  - queryCustomAuthIdentity
```
public CompletableFuture<QueryCustomAuthIdentityResponse> queryCustomAuthIdentity(QueryCustomAuthIdentityRequest request)
```
    指定者:
    
    queryCustomAuthIdentity 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryCustomAuthIdentity QueryCustomAuthIdentityRequest
    
    返回:
    
    QueryCustomAuthIdentityResponse
  - queryCustomAuthPermission
```
public CompletableFuture<QueryCustomAuthPermissionResponse> queryCustomAuthPermission(QueryCustomAuthPermissionRequest request)
```
    指定者:
    
    queryCustomAuthPermission 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryCustomAuthPermission QueryCustomAuthPermissionRequest
    
    返回:
    
    QueryCustomAuthPermissionResponse
  - queryMqttTraceDevice
```
public CompletableFuture<QueryMqttTraceDeviceResponse> queryMqttTraceDevice(QueryMqttTraceDeviceRequest request)
```
    description :
    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.
    - 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.
    指定者:
    
    queryMqttTraceDevice 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryMqttTraceDevice QueryMqttTraceDeviceRequest
    
    返回:
    
    QueryMqttTraceDeviceResponse
  - queryMqttTraceMessageOfClient
```
public CompletableFuture<QueryMqttTraceMessageOfClientResponse> queryMqttTraceMessageOfClient(QueryMqttTraceMessageOfClientRequest request)
```
    description :
    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.
    - 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.
    指定者:
    
    queryMqttTraceMessageOfClient 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryMqttTraceMessageOfClient QueryMqttTraceMessageOfClientRequest
    
    返回:
    
    QueryMqttTraceMessageOfClientResponse
  - queryMqttTraceMessagePublish
```
public CompletableFuture<QueryMqttTraceMessagePublishResponse> queryMqttTraceMessagePublish(QueryMqttTraceMessagePublishRequest request)
```
    description :
    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.
    - 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.
    指定者:
    
    queryMqttTraceMessagePublish 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryMqttTraceMessagePublish QueryMqttTraceMessagePublishRequest
    
    返回:
    
    QueryMqttTraceMessagePublishResponse
  - queryMqttTraceMessageSubscribe
```
public CompletableFuture<QueryMqttTraceMessageSubscribeResponse> queryMqttTraceMessageSubscribe(QueryMqttTraceMessageSubscribeRequest request)
```
    description :
    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.
    - 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.
    指定者:
    
    queryMqttTraceMessageSubscribe 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryMqttTraceMessageSubscribe QueryMqttTraceMessageSubscribeRequest
    
    返回:
    
    QueryMqttTraceMessageSubscribeResponse
  - querySessionByClientId
```
public CompletableFuture<QuerySessionByClientIdResponse> querySessionByClientId(QuerySessionByClientIdRequest request)
```
    description :
    You can call this operation up to 500 times per second.**** For more information, see Limits on QPS.
    - Each successful call to the QuerySessionByClientId operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    querySessionByClientId 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QuerySessionByClientId QuerySessionByClientIdRequest
    
    返回:
    
    QuerySessionByClientIdResponse
  - queryToken
```
public CompletableFuture<QueryTokenResponse> queryToken(QueryTokenRequest request)
```
    description :
    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.
    - Each successful call to the QueryToken operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    queryToken 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of QueryToken QueryTokenRequest
    
    返回:
    
    QueryTokenResponse
  - refreshDeviceCredential
```
public CompletableFuture<RefreshDeviceCredentialResponse> refreshDeviceCredential(RefreshDeviceCredentialRequest request)
```
    description :
    Limits
    
    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.
    
    指定者:
    
    refreshDeviceCredential 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of RefreshDeviceCredential RefreshDeviceCredentialRequest
    
    返回:
    
    RefreshDeviceCredentialResponse
  - registerCaCertificate
```
public CompletableFuture<RegisterCaCertificateResponse> registerCaCertificate(RegisterCaCertificateRequest request)
```
    description :
    Only ApsaraMQ for MQTT Enterprise Platinum Edition instances support this operation.
    - You can call this operation up to 500 times per second per Alibaba Cloud account. If you want to increase the limit, join the DingTalk group (ID: 35228338) to contact ApsaraMQ for MQTT technical support.
    指定者:
    
    registerCaCertificate 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of RegisterCaCertificate RegisterCaCertificateRequest
    
    返回:
    
    RegisterCaCertificateResponse
  - registerDeviceCredential
```
public CompletableFuture<RegisterDeviceCredentialResponse> registerDeviceCredential(RegisterDeviceCredentialRequest request)
```
    description :
    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 RegisterDeviceCredential operation increases the messaging transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    registerDeviceCredential 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of RegisterDeviceCredential RegisterDeviceCredentialRequest
    
    返回:
    
    RegisterDeviceCredentialResponse
  - revokeToken
```
public CompletableFuture<RevokeTokenResponse> revokeToken(RevokeTokenRequest request)
```
    description :
    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.
    - Each successful call to the RevokeToken operation increases the messaging transactions per second (TPS). This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    revokeToken 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of RevokeToken RevokeTokenRequest
    
    返回:
    
    RevokeTokenResponse
  - sendMessage
```
public CompletableFuture<SendMessageResponse> sendMessage(SendMessageRequest request)
```
    description :
    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.
    - Messages that are sent by calling the SendMessage operation cannot be forwarded to ApsaraMQ for RocketMQ. If you want to use an ApsaraMQ for MQTT broker to forward messages to ApsaraMQ for RocketMQ, use an SDK to send the messages. The SendMessage operation supports up to 1,000 queries per second (QPS). For more information, see QPS limits.
    - Each successful call to the SendMessage operation is calculated as a message transaction per second (TPS). This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    sendMessage 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of SendMessage SendMessageRequest
    
    返回:
    
    SendMessageResponse
  - setSniConfig
```
public CompletableFuture<SetSniConfigResponse> setSniConfig(SetSniConfigRequest request)
```
    指定者:
    
    setSniConfig 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of SetSniConfig SetSniConfigRequest
    
    返回:
    
    SetSniConfigResponse
  - tagResources
```
public CompletableFuture<TagResourcesResponse> tagResources(TagResourcesRequest request)
```
    指定者:
    
    tagResources 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of TagResources TagResourcesRequest
    
    返回:
    
    TagResourcesResponse
  - unRegisterDeviceCredential
```
public CompletableFuture<UnRegisterDeviceCredentialResponse> unRegisterDeviceCredential(UnRegisterDeviceCredentialRequest request)
```
    description :
    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 UnRegisterDeviceCredential operation increases the number of transactions per second (TPS) by one. This affects the billing of your instance. For more information, see Billing rules.
    指定者:
    
    unRegisterDeviceCredential 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of UnRegisterDeviceCredential UnRegisterDeviceCredentialRequest
    
    返回:
    
    UnRegisterDeviceCredentialResponse
  - untagResources
```
public CompletableFuture<UntagResourcesResponse> untagResources(UntagResourcesRequest request)
```
    指定者:
    
    untagResources 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of UntagResources UntagResourcesRequest
    
    返回:
    
    UntagResourcesResponse
  - updateCustomAuthIdentity
```
public CompletableFuture<UpdateCustomAuthIdentityResponse> updateCustomAuthIdentity(UpdateCustomAuthIdentityRequest request)
```
    指定者:
    
    updateCustomAuthIdentity 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of UpdateCustomAuthIdentity UpdateCustomAuthIdentityRequest
    
    返回:
    
    UpdateCustomAuthIdentityResponse
  - updateCustomAuthPermission
```
public CompletableFuture<UpdateCustomAuthPermissionResponse> updateCustomAuthPermission(UpdateCustomAuthPermissionRequest request)
```
    指定者:
    
    updateCustomAuthPermission 在接口中 AsyncClient
    
    参数:
    
    request - the request parameters of UpdateCustomAuthPermission UpdateCustomAuthPermissionRequest
    
    返回:
    
    UpdateCustomAuthPermissionResponse

类 DefaultAsyncClient

字段概要

构造器概要

方法概要

从类继承的方法 java.lang.Object

从接口继承的方法 com.aliyun.sdk.service.onsmqtt20200420.AsyncClient

字段详细资料

product

version

endpointRule

endpointMap

REQUEST

handler

构造器详细资料

DefaultAsyncClient

方法详细资料

close

activeCaCertificate

activeDeviceCertificate

addCustomAuthConnectBlack

addCustomAuthIdentity

addCustomAuthPermission

applyToken

batchQuerySessionByClientIds

closeConnection

createGroupId

deleteCaCertificate

deleteCustomAuthConnectBlack

deleteCustomAuthIdentity

deleteCustomAuthPermission

deleteDeviceCertificate

deleteGroupId

disasterDowngrade

disasterRecovery

getCaCertificate

getDeviceCertificate

getDeviceCredential

getRegisterCode

inactivateCaCertificate

inactivateDeviceCertificate

listCaCertificate

listDeviceCertificate

listDeviceCertificateByCaSn

listDeviceCredentialClientId

listGroupId

listInstances

listTagResources

queryCustomAuthConnectBlack

queryCustomAuthIdentity

queryCustomAuthPermission

queryMqttTraceDevice

queryMqttTraceMessageOfClient

queryMqttTraceMessagePublish

queryMqttTraceMessageSubscribe

querySessionByClientId

queryToken

refreshDeviceCredential

Limits

registerCaCertificate

registerDeviceCredential

revokeToken

sendMessage

setSniConfig

tagResources

unRegisterDeviceCredential

untagResources

updateCustomAuthIdentity

updateCustomAuthPermission