English

SINETStream ユーザガイド: SinetStreamWriterBytes

Android版のAPI

• パッケージ
  • jp.ad.sinet.stream.android.api
• 公開インタフェース
  • SinetStreamWriterBytes.SinetStreamWriterBytesListener
• 公開クラス
  • SinetStreamWriterBytes

インタフェース SinetStreamWriterBytes.SinetStreamWriterBytesListener

注意：
基底クラスのインタフェースSinetStreamWriter.SinetStreamWriterListener\<T\>をバイト列（byte[]）型に紐付けして継承したものであり、ここでの独自拡張はない。

メソッド概要

• onError
  • エラー検出時に呼ばれる。
• onPublished
  • ユーザ指定のメッセージ発行が完了した時に呼ばれる。
• onWriterStatusChanged
  • ブローカへのメッセージ送信可否状態が変化したときに呼ばれる。

メソッド詳細

onWriterStatusChanged

void onWriterStatusChanged(boolean isReady)

• 説明：
  • ブローカへのメッセージ送信可否状態が変化したときに呼ばれる。
  • 通知対象となる事象として以下の可能性がある。
    • ブローカへの接続完了
    • ブローカとの通信路切断
• 引数:
  • isReady - ブローカに「接続済み」であれば真、さもなくば偽

onPublished

void onPublished(@NonNull byte[] message,
                 @Nullable java.lang.Object userData)

• 説明：
  • ユーザ指定のメッセージ発行が完了した時に呼ばれる。
• 引数:
  • message - メソッドpublish()で指定されたバイト列データ
  • userData - メソッドpublish()で指定された任意のユーザデータ

onError

void onError(@NonNull java.lang.String description)

• 説明：
  • 何らかのエラー条件を満たしたときに呼ばれる。そのエラーはAndroid版のSINETStreamライブラリ内部、あるいはより下位層で検出したものかもしれない。
• 引数:
  • description - エラー内容の簡単な説明

クラスSinetStreamWriterBytes

注意：
基底クラスSinetStreamWriter\<T\>をバイト列（byte[]）型に紐付けして継承したものであり、ここでの独自拡張はない。

• SINETStreamシステムにおいて、「バイト列」送信用のライタ（= パブリッシャ）として機能するためのAPI関数一式を提供する。
• メッセージングシステムの性質上、下記のメソッドはいずれも非同期型の要求として扱う必要がある。
  • initialize
  • publish
  • terminate
• 本クラスの利用者は、呼び出し側のActivity、 あるいはFragmentにおいて、 SinetStreamWriterBytes.SinetStreamWriterBytesListener<byte[]>を実装し、処理結果やエラーの非同期通知を受けられるようにしなければならない。

入れ子クラス概要

• SinetStreamWriterBytes.SinetStreamWriterBytesListener
  • 内部インタフェース

コンストラクタ概要

• SinetStreamWriterBytes
  • SinetStreamWriterBytesのインスタンスを生成する。

メソッド概要

• initialize
  • ブローカに接続し、パブリッシャとしての初期処理を実施する。
• terminate
  • ブローカから切断し、確保した資源を解放する。
• publish
  • 付与のメッセージをブローカに発行する。

コンストラクタ詳細

public SinetStreamWriterBytes(@NonNull android.content.Context context)

• 説明：
  • SinetStreamWriterBytesのインスタンスを生成する。
• 引数:
  • context - SinetStreamWriterBytes.SinetStreamWriterBytesListenerを実装したアプリケーションコンテクスト、すなわち呼出側のActivityまたはFragmentそのもの。
• 例外:
  • java.lang.RuntimeException - 付与のコンテクストが所用のリスナーを実装していない

メソッド詳細

initialize

public void initialize(@NonNull java.lang.String serviceName,
                       @NonNull java.lang.String alias)

• 説明：
  • ブローカに接続し、バイト列送信用パブリッシャとしての初期処理を実施する。
  • 接続パラメータは外部の設定ファイルで規定される。
  • 処理中に何らかのエラーが発生した場合は、リスナー関数「onError()」で通知する。
• 引数:
  • serviceName - 設定ファイルで検索鍵となるサービス名
  • alias - システム秘匿領域に格納した「秘密鍵と証明書の対」に対応するエイリアス

terminate

public void terminate()

• 説明：
  • ブローカから切断し、確保した資源を解放する。
  • 処理中に何らかのエラーが発生した場合は、リスナー関数「onError()」で通知する。

publish

public void publish(@NonNull byte[] message,
                    @Nullable java.lang.Object userData)

• 説明：
  • ユーザ指定のバイト列データに関するメッセージ発行を要求する。
  • メッセージ発行処理が完了したら、リスナー関数「onPublished()」で通知する。
  • 処理中に何らかのエラーが発生した場合は、リスナー関数「onError()」で通知する。
• 引数:
  • message - 発行対象のバイト列データ
  • userData - ユーザ指定の任意オブジェクト。リスナー関数「onPublished()」でそのまま返却される。

付録

ライフサイクル

基底クラスSinetStreamWriterから継承したいくつかのクラスを内部使用とすることにより、初期処理の扱いを簡素化する。

    ( constructor )
          |
          V
      initialize()
          |
          | <---- onWriterStatusChanged(true)
          V
       publish()
          |
          | <---- onPublished()
          |            :
          | <---- onPublished()
          V
      terminate()
          |
          | <---- onWriterStatusChanged(false)
          V