Create CID

This interface is exclusive for MQ Enterprise Platinum edition users. For more information, go to Enterprise Platinum Edition Purchase Page.

Description

OnsSubscribeCreate interface creates a subscription relation with a specified Topic on the server.

Usage

After a new application is enabled and the Topic resource is registered, to subscribe to messages, you must create and register the subscription relation with the target Topic in the MQ console or by calling this API, then you can use the registered CID to subscribe to messages.

Request parameters

Response parameters

Related APIs

• OnsSubscribeDelete: deletes a subscription relation
• OnsSubscribeList: queries a list of subscription relations
• OnsSubscribeGet: precisely queries information of a subscription relation

Example

This example shows the process of creating a subscription relation “CID_MingduanTest” in the daily region to consume the messages of Mingduan_67dd.

 public static void main(String []args) {
            String regionId = "cn-hangzhou";
            String accessKey = "XXXXXXXXXXXXXXXXX";
            String secretKey = "XXXXXXXXXXXXXXXXX";
            String endPointName ="cn-hangzhou";
            String productName ="Ons";
            String domain ="ons.cn-hangzhou.aliyuncs.com";
            /**
            *Select Region based on the region you will access, and set the corresponding access point.
            */
            try {
                DefaultProfile.addEndpoint(endPointName，regionId，productName，domain);
            } catch (ClientException e) {
                e.printStackTrace();
            }
            IClientProfile profile= DefaultProfile.getProfile(regionId，accessKey，secretKey);
            IAcsClient iAcsClient= new DefaultAcsClient(profile);
          OnsSubscriptionCreateRequest request = new OnsSubscriptionCreateRequest();
            /**
            *OnsRegionId refers to the resource of the region of MQ required to be accessed by API.
            *This value must be selected and configured by the list obtained through the OnsRegionList method because OnsRegionId is changing, and cannot be written as a fixed value.
            */
          request.setOnsRegionId("daily");
          request.setPreventCache(System.currentTimeMillis());
          request.setAcceptFormat(FormatType.JSON);
          request.setTopic("Mingduan_67dd");
          request.setConsumerId("CID_MingduanTest");
          try {
              OnsSubscriptionCreateResponse response=iAcsClient.getAcsResponse(request);
              System.out.println(response.getRequestId());
          } catch (ServerException e) {
              e.printStackTrace();
          } catch (ClientException e) {
              e.printStackTrace();
          }
      }