1import com.bce.dts.client.ConsumerClient;
2import com.bce.dts.client.ConsumerClientImpl;
3import com.bce.dts.client.ConsumerListener;
4import com.bce.dts.client.RegionContext;
5import com.bce.dts.model.message.data.DataMessage;
6public class Demo {
7    public static void main(String[] args) {
8        // Initialize user identity
9        String akString = "填入您的Access Key ID";
10        String skString = "填入您的Secret Access Key";
11        String dtsId = "填入您在DTS控制台发布的数据订阅任务ID";
12          
13        // Initialize RegionContext
14        RegionContext regionContext = new RegionContext();
15        regionContext.setUsePublicIp(false);
16        regionContext.setAccessKey(akString);
17        regionContext.setSecretKey(skString);
18          
19        ConsumerClient consumerClient = new ConsumerClientImpl(regionContext);
20        consumerClient.addConcurrentListener(new ConsumerListener() { 
21            @Override
22            public void notify(DataMessage dataMsg) throws Exception {
23                    // TODO: process DataMessage as ur wish
24                System.out.println(dataMsg);
25            }
26              
27            @Override
28            public void noException(Exception paramException) {
29                    // TODO: handle exception when process DataMessage
30                    System.out.println("Listener exception");
31            }
32        });
33
34        consumerClient.start();  
35    }
36}