public static void main()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/example/ExampleUsage.java [17:51]

• 28 lines of code
• 1 McCabe index (conditional complexity)

    public static void main(String[] args) throws ProducerException, InterruptedException, ExecutionException {
        String project = System.getenv("PROJECT");
        String endpoint = System.getenv("ENDPOINT");
        String logStore = System.getenv("LOG_STORE");
        // init producer
        Producer producer = new LogProducer(new ProducerConfig());
        ProjectConfig projectConfig = new ProjectConfig(project, endpoint,
                getCredentialsProvider(),
                null);
        producer.putProjectConfig(projectConfig);

        // send logs
        ListenableFuture<Result> f =
                producer.send(project, logStore, buildLogItem());

        Result result = f.get();
        System.out.println(result.isSuccessful());
        System.out.println(result.getErrorMessage());

        producer.send(
                project, logStore, null, null, buildLogItem());
        producer.send(System.getenv("PROJECT"), System.getenv("LOG_STORE"), "", "", buildLogItem());

        f =
                producer.send(
                        project, logStore,
                        "topic",
                        "source",
                        buildLogItem());
        result = f.get();
        System.out.println(result.isSuccessful());
        System.out.println(result.getErrorMessage());

        producer.close();
    }