Create Topic

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

Description

Topic creation interface is usually used when new Topics are required. For example, to publish a new application, new Topics are required for the business logic.

Topic is globally unique and must not be duplicate; otherwise, the creation fails, where you need to fix the issue according to the error code.

Restrictions on primary accounts and sub-accounts

This interface is exclusively available for primary accounts by default, and cannot be used by RAM sub-accounts unless they are granted related permission.

Request parameters

Response parameters

Related APIs

• OnsTopicDelete: deletes a Topic
• OnsTopicList: views the list of Topics
• OnsPublishCreate: creates a publishing relation after creating a Topic
• OnsSubscribeCreate: creates a subscription after creating a Topic

Example

As a reference, this example shows the process of accessing from the end point China East, and creating a Topic with the name of “XXX” in the daily region.

    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);
        OnsTopicCreateRequest request = new OnsTopicCreateRequest();
        request.setAcceptFormat(FormatType.JSON);
        request.setTopic("XXXXXXXX");
        request.setQps(1000l);
        request.setRemark("test");
        request.setStatus(0);
            /**
            *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());
        try {
            OnsTopicCreateResponse response = client.getAcsResponse(request);
            System.out.println(response.getRequestId());
        }
        catch (ServerException e) {
            e.printStackTrace();
        }
        catch (ClientException e) {
            e.printStackTrace();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }