メッセージの送信方法

/**
 * 特定のアプリインスタンスへのメッセージ配信をADMにリクエストします。
 */
public void sendMessageToDevice(String registrationId, String accessToken) throws Exception
{
    // メッセージのJSONペイロード表現。
    JSONObject payload = new JSONObject();

    // メッセージ内容のキーと値のペアを定義し、メッセージペイロードに
    // 追加します。
    JSONObject data = new JSONObject();
    data.put("firstKey", "firstValue");
    data.put("secondKey", "secondValue");
    payload.put("data", data);

    // 連結キーを追加します。アプリインスタンスに対して、同じ連結キーを持つ
    // 複数のメッセージの配信が保留になっている場合、ADMでは最後に追加されたメッセージの
    // 配信が試行されます。
    payload.put("consolidationKey", "ADM_Enqueue_Sample");

    // メッセージに、expiresAfter値（1日間）を追加します。ターゲットのアプリインスタンスが
    // expiresAfter期間内にオンラインにならなかった場合、メッセージは配信されません。
    payload.put("expiresAfter", 86400);

    // メッセージにpriorityを追加します。priorityの値によって、デバイスがDoze／アイドルモードの場合に
    // メッセージが配信されるかどうかが決まります。
    payload.put("priority", "high");


    // メッセージをJSONオブジェクトから文字列に変換します。
    String payloadString = payload.toString();

    // ベースURLを設定します。このURLには、目的のアプリインスタンスの登録IDに
    // 置き換わる部分を含めてください。String.formatを使用してURLを作成するため、
    // %1$sは置き換わる部分を表します。
    String admUrlTemplate = "https://api.amazon.com/messaging/registrations/%1$s/messages";

    URL admUrl = new URL(String.format(admUrlTemplate,registrationId));

    // POSTリクエスト用のHTTPS接続を生成します。HTTP接続は
    // 行えません。
    HttpsURLConnection conn = (HttpsURLConnection) admUrl.openConnection();
    conn.setRequestMethod("POST");
    conn.setDoOutput(true);

    // コンテンツタイプを設定し、ヘッダーを受け取ります。
    conn.setRequestProperty("content-type", "application/json");
    conn.setRequestProperty("accept", "application/json");
    conn.setRequestProperty("X-Amzn-Type-Version", "com.amazon.device.messaging.ADMMessage@1.0");
    conn.setRequestProperty("X-Amzn-Accept-Type", "com.amazon.device.messaging.ADMSendResult@1.0");

    // ヘッダーとして認証トークンを追加します。
    conn.setRequestProperty("Authorization", "Bearer " + accessToken);

    // 接続の出力ストリームを取得し、メッセージペイロードを書き込みます。
    OutputStream os = conn.getOutputStream();
    os.write(payloadString.getBytes(), 0, payloadString.getBytes().length);
    os.flush();
    conn.connect();

    // 接続からレスポンスコードを取得します。
    int responseCode = conn.getResponseCode();

    // 失敗のレスポンスを受信したかどうか確認し、受信した場合は失敗の理由を取得します。
    if( responseCode != 200)
    {
        if( responseCode == 401 )
        {
            // レスポンスコード401を受信した場合は、アクセストークンの期限が切れていることを意味します。トークンを更新します。
            // このリクエストは再試行できます。
        }

        String errorContent = parseResponse(conn.getErrorStream());
        throw new RuntimeException(String.format("ERROR: The enqueue request failed with a " +
                                         "%d response code, with the following message: %s",
                                         responseCode, errorContent));
    }
    else
    {
        // リクエストに成功しました。レスポンスには、アプリインスタンスの正規登録IDが含まれていますが、
        // リクエストに使用されたものとは異なることもあります。

        String responseContent = parseResponse(conn.getInputStream());
        JSONObject parsedObject = new JSONObject(responseContent);

        String canonicalRegistrationId = parsedObject.getString("registrationID");

        // 2つの登録IDが異なるかどうか確認します。
        if(!canonicalRegistrationId.equals(registrationId))
        {
            // この時点で、このアプリインスタンス固有の適切な登録IDを使用して、
            // 登録IDの値が格納されるデータ構造を更新する必要があります。
        }
    }

}

private String parseResponse(InputStream in) throws Exception
{
    // 入力ストリームから読み取り、Stringに変換します。
    InputStreamReader inputStream = new InputStreamReader(in);
    BufferedReader buff = new BufferedReader(inputStream);

    StringBuilder sb = new StringBuilder();
    String line = buff.readLine();
    while(line != null)
   {
      sb.append(line);
      line = buff.readLine();
    }

    return sb.toString();
}