ステップ 5: OAuth べアラートークンログインを使用してコネクタを使用する

1/*
2 * Copyright (c) 2016, salesforce.com, inc. All rights reserved. Licensed under the BSD 3-Clause license. For full
3 * license text, see LICENSE.TXT file in the repo root or https://opensource.org/licenses/BSD-3-Clause
4 */
5package com.salesforce.emp.connector.example;
6
7import java.net.MalformedURLException;
8import java.net.URL;
9import java.util.Map;
10import java.util.concurrent.TimeUnit;
11import java.util.function.Consumer;
12
13import com.salesforce.emp.connector.BayeuxParameters;
14import com.salesforce.emp.connector.EmpConnector;
15import com.salesforce.emp.connector.TopicSubscription;
16
17/**
18 * An example of using the EMP connector using bearer tokens
19 *
20 * @author hal.hildebrand
21 * @since 202
22 */
23public class BearerTokenExample {
24    public static void main(String[] argv) throws Exception {
25        if (argv.length < 2 || argv.length > 4) {
26            System.err.println(
27                "Usage: BearerTokenExample url token topic [replayFrom]");
28            System.exit(1);
29        }
30        long replayFrom = EmpConnector.REPLAY_FROM_EARLIEST;
31        if (argv.length == 4) {
32            replayFrom = Long.parseLong(argv[3]);
33        }
34
35        BayeuxParameters params = new BayeuxParameters() {
36
37            @Override
38            public String bearerToken() {
39                return argv[1];
40            }
41
42            @Override
43            public URL host() {
44                try {
45                    return new URL(argv[0]);
46                } catch (MalformedURLException e) {
47                    throw new IllegalArgumentException(
48                        String.format("Unable to create url: %s", argv[0]), e);
49                }
50            }
51        };
52
53        Consumer<Map<String, Object>> consumer = event -> System.out.println(
54                String.format("Received:\n%s", event));
55        EmpConnector connector = new EmpConnector(params);
56
57        connector.start().get(5, TimeUnit.SECONDS);
58
59        TopicSubscription subscription = connector.subscribe(argv[2], 
60            replayFrom, consumer).get(5, TimeUnit.SECONDS);
61
62        System.out.println(String.format("Subscribed: %s", subscription));
63    }
64}