この文章は Salesforce 機械翻訳システムを使用して翻訳されました。詳細はこちらをご参照ください。

ユーザ名とパスワードのログインを使用する Java クライアントの実行

EMP コネクタを使用して、ユーザ名とパスワードの認証によってチャネル��登録する Java クライアントを実行します。

GitHub から EMP コネクタプロジェクトを入手します。「プロジェクトをダウンロードして構築する」を参照してください。

/src/main/java/com/salesforce/emp/connector/example フォルダで、LoginExample.java ソースファイルを開きます。

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

LoginExample クラスを実行し、次の引数を指定します。

引数	値
`username`	ログインユーザのユーザ名。
`password`	`username` (ログインユーザ) のパスワード。
`channel`	`/u/notifications/ExampleUserChannel`

このサンプルでは、過去 24 時間以内で最も早く保存されたイベントを取得します。必要に応じて、異なるイベントを受信するために、最後の引数として再生 ID を含めることができます。有効な値は、次のとおりです。

-1 — 登録後に送信されたすべての新規イベントを取得します。
-2 — 登録後に送信されたすべての新規イベントおよび過去 24 時間以内のすべての過去のイベントを取得します。
特定の番号 — 指定された再生 ID を持つイベントより後に発生したすべてのイベントを取得します。

REST リソースを使用してこのクライアントアプリケーションを実行し、通知を生成すると、出力は次のようになります。

1Subscribed: Subscription [/u/notifications/ExampleUserChannel:-2]
2Received:
3{payload=Broadcast message to all subscribers, event={createdDate=2016-12-13T00:57:36.020Z, replayId=1}}
4Received:
5{payload=Another message, event={createdDate=2016-12-13T00:58:16.591Z, replayId=2}}

一般的に、本番環境でコードを実行するときには、他のユーザのユーザ名とパスワードを処理しないようにします。本番環境では、ログインを OAuth に委任してください。次の手順では、OAuth を使用してストリーミング API に接続します。

ストリーミング API 開発者ガイド

ユーザ名とパスワードのログインを使用する Java クライアントの実行