ステップ 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 */
22public class BearerTokenExample {
23    public static void main(String[] argv) throws Exception {
24        if (argv.length < 2 || argv.length > 4) {
25            System.err.println(
26                "Usage: BearerTokenExample url token topic [replayFrom]");
27            System.exit(1);
28        }
29        long replayFrom = EmpConnector.REPLAY_FROM_EARLIEST;
30        if (argv.length == 4) {
31            replayFrom = Long.parseLong(argv[3]);
32        }
33
34        BayeuxParameters params = new BayeuxParameters() {
35
36            @Override
37            public String bearerToken() {
38                return argv[1];
39            }
40
41            @Override
42            public URL host() {
43                try {
44                    return new URL(argv[0]);
45                } catch (MalformedURLException e) {
46                    throw new IllegalArgumentException(
47                        String.format("Unable to create url: %s", argv[0]), e);
48                }
49            }
50        };
51
52        Consumer<Map<String, Object>> consumer = event -> System.out.println(
53                String.format("Received:\n%s", event));
54        EmpConnector connector = new EmpConnector(params);
55
56        connector.start().get(5, TimeUnit.SECONDS);
57
58        TopicSubscription subscription = connector.subscribe(argv[2], 
59            replayFrom, consumer).get(5, TimeUnit.SECONDS);
60
61        System.out.println(String.format("Subscribed: %s", subscription));
62    }
63}