import com.bce.dts.client.ConsumerClient;
import com.bce.dts.client.ConsumerClientImpl;
import com.bce.dts.client.ConsumerListener;
import com.bce.dts.client.RegionContext;
import com.bce.dts.model.message.data.DataMessage;
public class Demo {
    public static void main(String[] args) {
        // Initialize user identity
        String akString = "填入您的Access Key ID";
        String skString = "填入您的Secret Access Key";
        String dtsId = "填入您在DTS控制台发布的数据订阅任务ID";
          
        // Initialize RegionContext
        RegionContext regionContext = new RegionContext();
        regionContext.setUsePublicIp(false);
        regionContext.setAccessKey(akString);
        regionContext.setSecretKey(skString);
          
        ConsumerClient consumerClient = new ConsumerClientImpl(regionContext);
        consumerClient.addConcurrentListener(new ConsumerListener() { 
            @Override
            public void notify(DataMessage dataMsg) throws Exception {
                    // TODO: process DataMessage as ur wish
                System.out.println(dataMsg);
            }
              
            @Override
            public void noException(Exception paramException) {
                    // TODO: handle exception when process DataMessage
                    System.out.println("Listener exception");
            }
        });

        consumerClient.start();  
    }
}