tencent cloud

package com.qcloud.biz;
import com.qcloud.dts.context.NetworkEnv;
import com.qcloud.dts.context.SubscribeContext;
import com.qcloud.dts.message.ClusterMessage;
import com.qcloud.dts.message.DataMessage;
import com.qcloud.dts.subscribe.ClusterListener;
import com.qcloud.dts.subscribe.DefaultSubscribeClient;
import com.qcloud.dts.subscribe.SubscribeClient;
import java.util.List;
public class Main {
    public static void main(String[] args) throws Exception {

        SubscribeContext context=new SubscribeContext();
        // User `secretId` and `secretKey`. We recommend that you use a sub-account key and follow the principle of minimum permission to reduce risks. For information on how to obtain a sub-account key, visit https://www.tencentcloud.com/document/product/598/32675.
        context.setSecretId("AKID-522dabxxxxxxxxxxxxxxxxxx");  
        context.setSecretKey("AKEY-0ff4cxxxxxxxxxxxxxxxxxxxx");
        /*****************Code modification starts****************/
        // If you do not set the `region` parameter, the API 2.0 will still be used for authentication even after it is deprecated.
        // However, the authentication via API 2.0 will fail then, so the SDK will not work properly.
        // Set `region` for subscription channel.
        context.setRegion("ap-chongqing");
        /*****************Code modification ends******************/


        // Create a client
        SubscribeClient client=new DefaultSubscribeClient(context);
        // Create a subscription listener
        ClusterListener listener= new ClusterListener() {
            @Override
            public void notify(List<ClusterMessage> messages) throws Exception {
                // Consume the subscribed data
                for(ClusterMessage m:messages){
                    for(DataMessage.Record.Field f:m.getRecord().getFieldList()){
                        if(f.getFieldname().equals("id")){
                            System.out.println("seq:"+f.getValue());
                        }
                        DataMessage.Record record  = m.getRecord();
                    }
                    // Acknowledge the consumption
                    m.ackAsConsumed();
                }
            }
            @Override
            public void onException(Exception e){
                System.out.println("listen exception"+e);
            }};
        // Add a listener
        client.addClusterListener(listener);
        // Configure the requested subscription channel
        client.askForGUID("dts-channel-r0M8kKsSyRZmSxQt");
        // Start the client
        client.start();
    }
}