package com.tencentcloudapi.cls;

import com.tencentcloudapi.cls.producer.errors.ProducerException;
import org.junit.Test;

public class AsyncProducerClientTest {

    @Test
    public void testAsyncProducerClient() throws ProducerException, InterruptedException {
       String endpoint = "ap-guangzhou.cls.tencentcs.com";
       // 一時キー secretId、必須入力
       String secretId = "";
       // 一時キー secretKey、必須入力
       String secretKey = "";
       // 一時キー secretToken、必須入力
       String secretToken = "";
       // ログトピックID、必須入力
       String topicId = "";

       final AsyncProducerConfig config = new AsyncProducerConfig(endpoint, secretId, secretKey, 
            NetworkUtils.getLocalMachineIP(), secretToken);

       // クライアントインスタンスを構築します。
       final AsyncProducerClient client = new AsyncProducerClient(config);

       for (int i = 0; i < 10000; ++i) {
           List<LogItem> logItems = new ArrayList<>();
           int ts = (int) (System.currentTimeMillis() / 1000);
           LogItem logItem = new LogItem(ts);
           logItem.PushBack(new LogContent("__CONTENT__", "こんにちは、深センから来ました|hello world"));
           logItem.PushBack(new LogContent("city", "guangzhou"));
           logItem.PushBack(new LogContent("logNo", Integer.toString(i)));
           logItem.PushBack(new LogContent("__PKG_LOGID__", (String.valueOf(System.currentTimeMillis()))));
           logItems.add(logItem);
           client.putLogs(topicId, logItems, result -> System.out.println(result.toString()));
       }
       client.close();
    }
}