第 5 章   イベント通知サービス API リファレンス


この章では、ENS API について説明します。この章は次の 4 つの節に分かれています。

• パブリッシャ API

• サブスクライバ API

• 公開および購読ディスパッチャー API

• コーディング例

パブリッシャ API の関数リスト

---

パブリッシャ関数について、次の 表 5-1 で説明します。

表 5-1 ENS パブリッシャ API の関数リスト 

定義/関数	説明
publisher_t	パブリッシャの定義
publisher_cb_t	非同期呼び出しの結果を確認する汎用コールバック関数
publisher_new_a	新規の非同期パブリッシャを作成する
publisher_new_s	新規の同期パブリッシャを作成する
publish_a	非同期通知を通知サービスに送信する
publish_s	同期通知を通知サービスに送信する
publisher_delete	パブリッシャのセッションを終了する
publisher_get_subscriber	パブリッシャの証明書を使用してサブスクライバを作成する
renl_create_publisher	RENL を作成する。end2end_ack の呼び出しが有効になる
renl_cancel_publisher	RENL をキャンセルする

サブスクライバ API の関数リスト

---

サブスクライバ関数について、次の表 5-2 で説明します。

表 5-2 ENS サブスクライバ API の関数リスト 

定義/関数	説明
subscriber_t	サブスクライバの定義
subscription_t	購読の定義
subscriber_cb_t	非同期呼び出しの結果を確認する汎用コールバック関数
subscriber_notify_cb_t	通知の受信時に呼び出される同期コールバック
subscriber_new_a	新規非同期サブスクライバを作成する
subscriber_new_s	新規同期サブスクライバを作成する
subscribe_a	非同期購読を確立する
unsubscribe_a	非同期購読をキャンセルする
subscriber_delete	サブスクライバを終了する
subscriber_get_publisher	サブスクライバの証明書を使用してパブリッシャを作成する
renl_create_subscriber	RENL のサブスクライバ側を作成する
renl_cancel_subscriber	RENL をキャンセルする

公開および購読ディスパッチャーの関数リスト

---

公開および購読ディスパッチャー関数について、次の表 5-3 で説明します。

表 5-3 ENS 公開および購読ディスパッチャーの関数リスト 

定義/関数	説明
pas_dispatcher_t	公開および購読ディスパッチャーの定義
pas_dispatcher_new	ディスパッチャーを作成する
pas_dispatcher_delete	pas_dispatcher_new で作成したディスパッチャーを削除する
pas_dispatch	イベント通知環境のディスパッチループを開始する
pas_shutdown	pas_dispatch で開始したイベント通知環境のディスパッチループを停止する

パブリッシャ API

パブリッシャ API は、次の 1 つの定義と 9 つの関数から構成されています。

• publisher_t

• publisher_cb_t

• publisher_new_a

• publisher_new_s

• publish_a

• publish_s

• publisher_delete

• publisher_get_subscriber

• renl_create_publisher

• renl_cancel_publisher

publisher_t

目的
パブリッシャ

構文
typedef struct enc_struct publisher_t;

パラメータ
なし

戻り値
なし

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

publisher_cb_t

目的
非同期呼び出しの結果を確認するため、ENS によって呼び出される汎用コールバック関数

構文
typedef void (*publisher_cb_t) (void *arg, int rc, void *data);

パラメータ

arg	呼び出し元によって渡されるコンテキスト変数
rc	リターンコード
data	パブリッシャの作成の場合、新しく作成されたコンテキストが含まれる

戻り値
なし

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

publisher_new_a

目的
新規非同期パブリッシャを作成します。

構文
void publisher_new_a (pas_dispatcher_t *disp,
                      void *worker,
                      const char *host,
                      unsigned short port,
                      publisher_cb_t cbdone,
                      void *cbarg);

パラメータ

disp	pas_dispatcher_new によって返される P&S スレッドプールコンテキスト
worker	アプリケーションワーカー。NULL 以外の場合、ENS によって作成された既存のワーカーにグループ化され、現在のパブリッシャセッションで使用される。これは、複数のスレッドによってパブリッシャデータが同時にアクセスされるのを防ぐために使用される
host	通知サーバのホスト名
port	通知サーバのポート番号
cbdone	パブリッシャが正常に作成されたとき、または作成できなかったときに呼び出されるコールバック cbdone には次の 3 つのパラメータがある cbarg 最初の引数 状態コード ゼロ以外の場合は、パブリッシャが作成できなかったことを示し、値は失敗の原因を表す 新規アクティブパブリッシャ
cbarg	cbdone の最初の引数

戻り値
なし。cbdone コールバックの 3 番目の引数として、新規アクティブパブリッシャが渡されます。

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

publisher_new_s

目的
新規同期パブリッシャを作成します。

構文
publisher_t *publisher_new_s (pas_dispatcher_t *disp,
                              void *worker,
                              const char *host,
                              unsigned short port);

パラメータ

disp	pas_dispatcher_new によって返される P&S スレッドプールコンテキスト
worker	アプリケーションワーカー。NULL 以外の場合、ENS によって作成された既存のワーカーにグループ化され、現在のパブリッシャセッションで使用される。また、複数のスレッドによってパブリッシャデータが同時にアクセスされることを防ぐために使用する
host	通知サーバのホスト名
port	通知サーバのポート

戻り値
新規アクティブパブリッシャ (publisher_t)

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

publish_a

目的
非同期通知を通知サービスに送信します。

構文
void publish_a (publisher_t *publisher,
                const char *event_ref,
                const char *data,
                unsigned int datalen,
                publisher_cb_t cbdone,
                publisher_cb_t end2end_ack,
                void *cbarg,
                unsigned long timeout);

パラメータ

publisher_t	アクティブなパブリッシャ
event_ref	イベント参照。変更されたリソースを識別する URI
data	イベントデータ。通知メッセージの本文。MIME オブジェクトであることが必要。通知サービスに対して不透明で、通知サービスはイベントのサブスクライバへの中継だけを行う
datalen	バイト単位のデータ長
cbdone	通知サービスによってデータが受け入れられた場合、または受け入れられなかったと見なされた場合に呼び出されるコールバック。通知が受け入れられるかどうかは、使用するプロトコルによって左右される。プロトコルには、トランスポート送達確認 (TCP) や独自の送達確認メカニズムを選択できる
end2end_ack	RENL 内のサブスクライバピアから送達確認を受信したあとに呼び出されるコールバック関数。RENL のコンテキスト内でだけ使用される
cbarg	cbdone または end2end_ack が呼び出されるときの最初の引数
timeout	RENL の完了を待機する時間の長さ

戻り値
なし

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

publish_s

目的
同期通知を通知サービスに送信します。

構文
int publish_s (publisher_t *publisher,
               const char *event_ref,
               const char *data,
               unsigned int datalen);

パラメータ

publisher	アクティブなパブリッシャ
event_ref	イベント参照。変更されたリソースを識別する URI
data	イベントデータ。通知メッセージの本文。MIME オブジェクトであることが必要。通知サービスに対して不透明で、通知サービスはイベントのサブスクライバへの中継だけを行う
datalen	バイト単位のデータ長

戻り値
成功した場合はゼロ、失敗した場合は障害コード。RENL の場合、サブスクライバが通知を完全に処理し、送達確認が完了するまで、呼び出しは返されません。

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

publisher_delete

目的
パブリッシャのセッションを終了します。

構文
void publisher_delete (publisher_t *publisher);

パラメータ

publisher

削除対象のパブリッシャ

戻り値
なし

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

publisher_get_subscriber

目的
パブリッシャの証明書を使ってサブスクライバを作成します。

構文
struct subscriber_struct * publisher_get_subscriber(publisher_t *publisher);

パラメータ

publisher

サブスクライバを作成するときに使用される証明書を持つパブリッシャ

戻り値
作成に成功した場合はそのサブスクライバ、失敗した場合は NULL。作成に失敗した場合は、subscriber_new を使用してサブスクライバを作成します。

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

renl_create_publisher

目的
RENL を宣言します。これにより end2end_ack の呼び出しが有効になります。この呼び出しが返されたあとは、指定されたパブリッシャおよびサブスクライバに対応する送達確認が受信されたときに、end2end_ack 引数が呼び出されます。

構文
void renl_create_publisher (publisher_t *publisher,
                            const char *renl_id,
                            const char *subscriber,
                            publisher_cb_t cbdone,
                            void *cbarg);

パラメータ

publisher	アクティブなパブリッシャ
renl_id	一意の RENL 識別子。これにより、2 つのピア間に複数の RENL を設定できる
subscriber	認証されたピアの ID
cbdone	RENL が確立されたときに呼び出されるコールバック
cbarg	cbdone が呼び出されるときの cbdone の最初の引数

戻り値
なし

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

renl_cancel_publisher

目的
RENL をキャンセルします。キャンセルしても、通知は送信されます。ただし、クライアントの送達確認が着信しても、パブリッシャの end2end_ack 引数は呼び出されません。パブリッシャを削除すると、RENL がすべて自動的に削除されます。このため、パブリッシャを削除する前に、この関数を呼び出して RENL 関連のメモリを解放する必要はありません。

構文
void renl_cancel_publisher (renl_t *renl);

パラメータ

renl	キャンセル対象の RENL

戻り値
なし

[パブリッシャ API 一覧に戻る]

[第 5 章の先頭に戻る]

サブスクライバ API

サブスクライバ API は、次の 2 つの定義と 10 の関数から構成されています。

• subscriber_t

• subscription_t

• subscriber_cb_t

• subscriber_notify_cb_t

• subscriber_new_a

• subscriber_new_s

• subscribe_a

• unsubscribe_a

• subscriber_delete

• subscriber_get_publisher

• renl_create_subscriber

• renl_cancel_subscriber

subscriber_t

目的
サブスクライバ

構文
typedef struct enc_struct subscriber_t;

パラメータ
なし

戻り値
なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscription_t

目的
購読

構文
typedef struct subscription_struct subscription_t;

パラメータ
なし

戻り値
なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscriber_cb_t

目的
非同期呼び出しの結果を確認するために、ENS によって呼び出される汎用コールバック関数

構文
typedef void (*subscriber_cb_t) (void *arg,
                                 int rc,
                                 void *data);

パラメータ

arg	呼び出し元によって渡されるコンテキスト変数
rc	リターンコード
data	サブスクライバの作成の場合、新しく作成されたコンテキストが含まれる

戻り値
なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscriber_notify_cb_t

目的
通知の受信時に呼び出されるサブスクライバコールバック

構文
typedef void (*subscriber_notify_cb_t) (void *arg,
                                        char *event,
                                        char *data,
                                        int datalen);

パラメータ

arg	サブスクライバに渡されるコンテキストポインタ (notify_arg)
event	イベント参照 (URI)。この通知イベント参照は購読と対応する。ただし、uid などのイベント属性と呼ばれる情報が追加されている場合もある
data	通知の本文。MIME オブジェクト
datalen	データの長さ

戻り値
成功した場合はゼロ、失敗した場合はゼロ以外の値

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscriber_new_a

目的
新規非同期サブスクライバを作成する

構文
void subscriber_new_a (pas_dispatcher_t *disp,
                       void *worker,
                       const char *host,
                       unsigned short port,
                       subscriber_cb_t cbdone,
                       void *cbarg);

パラメータ

disp	pas_dispatcher_new によって返されるスレッドディスパッチャーコンテキスト
worker	アプリケーションワーカー。NULL 以外の場合、ENS によって作成された既存のワーカーにグループ化され、現在のサブスクライバセッションで使用される。また、複数のスレッドによってサブスクライバデータが同時にアクセスされるのを防ぐために使用する。呼び出し元が GDisp コンテキストを作成して振り分ける場合にだけ使用できる
host	通知サーバのホスト名または IP アドレス
port	購読サービスのポート番号
cbdone	サブスクライバセッションがアクティブになり、購読依頼を発行できるようになったときに呼び出されるコールバック cbdone には次の 3 つのパラメータがあります。 cbarg 最初の引数 状態コード ゼロ以外の場合は、サブスクライバを作成できなかったことを示し、値は失敗の原因を示す 新規アクティブサブスクライバ (subscriber_t)
cbarg	cbdone の最初の引数

戻り値
なし。cbdone コールバックの 3 番目の引数として、新規アクティブサブスクライバが渡されます。

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscriber_new_s

目的
新規同期サブスクライバを作成します。

構文
subscriber_t *subscriber_new_s (pas_dispatcher_t *disp,
                                const char *host,
                                unsigned short port);

パラメータ

disp	pas_dispatcher_new によって返される公開および購読ディスパッチャ
worker	アプリケーションワーカー。NULL 以外の場合、ENS によって作成された既存のワーカーにグループ化され、現在のパブリッシャセッションで使用される。また、複数のスレッドによってパブリッシャデータが同時にアクセスされるのを防ぐために使用する。呼び出し元が GDisp コンテキストを作成して振り分ける場合にだけ使用できます
host	通知サーバのホスト名または IP アドレス
port	購読サービスのポート番号

戻り値
新規アクティブサブスクライバ (subscriber_t)

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscribe_a

目的

非同期購読を確立します。

構文
void subscribe_a (subscriber_t *subscriber,
                  const char *event_ref,
                  subscriber_notify_cb_t notify_cb,
                  void *notify_arg,
                  subscriber_cb_t cbdone,
                  void *cbarg):

パラメータ

subscriber	サブスクライバ
event_ref	イベント参照。イベントのソースを識別する URI
notify_cb	この購読に対応する通知を受信したときに呼び出されるコールバック
notify_arg	notify_arg の最初の引数。サブスクライバはアクティブな状態のまま、任意のスレッドから任意のタイミングに呼び出される場合がある
cbdone	購読依頼が完了したときに呼び出される。次の 3 つのパラメータを持つ cbarg (以下の説明を参照) 状態コード 不透明な購読オブジェクトへのポインタ
cbarg	cbdone の最初の引数

戻り値
なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

unsubscribe_a

目的

非同期購読をキャンセルします。

構文
void unsubscribe_a (subscriber_t *subscriber,
                    subscription_t *subscription,
                    subscriber_cb_t cbdone,
                    void *cbarg);

パラメータ

subscriber	削除対象のサブスクライバ
subscription	キャンセル対象の購読
cbdone	購読の中止が完了したときに呼び出される。次の 3 つのパラメータを持つ cbarg (以下の説明を参照) 状態コード 不透明購読オブジェクトへのポインタ
cbarg	cbdone の最初の引数

戻り値
なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscriber_delete

目的
サブスクライバを削除します。

構文
void subscriber_delete (subscriber_t *subscriber);

パラメータ

subscriber

削除対象のサブスクライバ

戻り値

なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

subscriber_get_publisher

目的
サブスクライバの証明書を使ってパブリッシャを作成します。

構文
struct publisher_struct *subscriber_get_publisher (subscriber_t *subscriber);

パラメータ

subscriber

パブリッシャを作成するときに使用される証明書を持つサブスクライバ

戻り値
作成に成功した場合はそのパブリッシャ、失敗した場合は NULL。作成に失敗した場合は、publisher_new を使用してサブスクライバを作成します。

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

renl_create_subscriber

目的
RENL のサブスクライバ側を作成します。

構文
renl_t *renl_create_subscriber (subscription_t *subscription,
                                const char *renl_id,
                                const char *publisher);

パラメータ

subscription	購読
renl_id	一意の RENL 識別子。これにより、2 つのピア間に複数の RENL を設定できる
publisher	認証されたピアの ID

戻り値
不透明 RENL オブジェクト

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

renl_cancel_subscriber

目的
RENL をキャンセルします。ただし、購読はキャンセルされません。この購読に対して以降の送信確認が行われないことを ENS に知らせます。この関数により、RENL オブジェクトが破棄されるため、アプリケーションはこの RENL をそれ以降使用できなくなります。購読をキャンセルすると、RENL はすべて自動的に削除されます。このため、サブスクライバを削除する前に、この関数を呼び出して RENL 関連のメモリを解放する必要はありません。

構文
void renl_cancel_subscriber (renl_t *renl);

パラメータ

renl	キャンセル対象の RENL

戻り値
なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

公開および購読ディスパッチャー API

公開および購読ディスパッチャー API は、次の 1 つの定義と 4 つの関数から構成されています。

• pas_dispatcher_t

• pas_dispatcher_new

• pas_dispatcher_delete

• pas_dispatch

• pas_shutdown

  
  

  ---

  注	サポートされているスレッドディスパッチャーは、GDisp (libasync) だけです。

  ---

  
  

pas_dispatcher_t

目的
公開および購読ディスパッチャー

構文
typedef struct pas_dispatcher_struct pas_dispatcher_t;

パラメータ
なし

戻り値
なし

[サブスクライバ API 一覧に戻る]

[第 5 章の先頭に戻る]

pas_dispatcher_new

目的
ディスパッチャーを作成または通知します。

構文
pas_dispatcher_t *pas_dispatcher_new (void *disp);

パラメータ

disp	ディスパッチャーコンテキスト。NULL の場合、通知のディスパッチを開始するには、アプリケーションから pas_dispatch を呼び出す必要がある NULL 以外の場合、libasync ディスパッチャーが使われる

戻り値
パブリッシャまたはサブスクライバを作成するときに使用するディスパッチャー (pas_dispatcher_t)

[公開および購読ディスパッチャー API 一覧に戻る]

[第 5 章の先頭に戻る]

pas_dispatcher_delete

目的
pas_dispatcher_new で作成したディスパッチャーを削除します。

構文
void pas_dispatcher_delete (pas_dispatcher_t *disp);

パラメータ

disp	イベント通知クライアント環境

戻り値
なし

[公開および購読ディスパッチャー API 一覧に戻る]

[第 5 章の先頭に戻る]

pas_dispatch

目的
イベント通知環境のディスパッチループを開始します。アプリケーションで独自のスレッドプールを使用している場合は何も起きません。

構文
void pas_dispatch (pas_dispatcher_t *disp);

パラメータ

disp

新規ディスパッチャ

戻り値
なし

[公開および購読ディスパッチャー API 一覧に戻る]

[第 5 章の先頭に戻る]

pas_shutdown

目的
pas_dispatch で開始したイベント通知環境のディスパッチループを停止します。アプリケーションが提供したディスパッチャーを pas_dispatcher_new に渡していた場合には何も起きません。

構文
void pas_shutdown (pas_dispatcher_t *disp);

パラメータ

disp	停止対象のディスパッチャーコンテキスト

戻り値

なし

[公開および購読ディスパッチャー API 一覧に戻る]

[第 5 章の先頭に戻る]

コーディング例

---

iPlanet Calendar Server には完全な ENS 実装が付属しています。必要であれば、これらの API を使用して ENS をカスタマイズできます。次の 4 つのコードサンプル (簡単なパブリッシャとサブスクライバ、および信頼性の高いパブリッシャとサブスクライバ) は、API の使い方を示しています。コーディング例は、この製品の次のディレクトリにあります。

/opt/SUNWics5/cal/csapi/samples/ens

簡単なパブリッシャとサブスクライバ

これらのコーディング例では、簡単な連携動作する非同期パブリッシャおよびサブスクライバを確立します。

パブリッシャのコードサンプル

/*
 * Copyright 2000 by Sun Microsystems, Inc.
 * All rights reserved
 *
 * apub :簡単な連携動作する非同期パブリッシャ
 *
 * 構文 :
 * apub ホスト名 ポート番号
 */

#include <stdlib.h>
#include <stdio.h>

#include "pasdisp.h"
#include "publisher.h"

static pas_dispatcher_t *disp = NULL;
static publisher_t *_publisher = NULL;
static int _shutdown = 0;

static void _read_stdin();

static void _exit_usage()
{
printf("\n使用法 :\napub ホスト名 ポート番号\n");
exit(5);
}

static void _exit_error(const char *msg)
{
printf("%s\n", msg);
exit(1);
}

static void _call_shutdown()
{
_shutdown = 1;
pas_shutdown(disp);
}

static void _open_ack(void *arg, int rc, void *enc)
{
_publisher = (publisher_t *)enc;
(void *)arg;

if (!_publisher)
{
printf("状態 %d のため、パブリッシャの作成に失敗しました\n", rc);
_call_shutdown();
return;
}

_read_stdin();

return;
}

static void _publish_ack(void *arg, int rc, void *ignored)
{
(void *)ignored;

free(arg);

if (rc != 0)
{

printf("状態 %d のため、公開に失敗しました\n", rc);

_call_shutdown();

return;
}

_read_stdin();

return;
}

static void _read_stdin()
{

static char input[1024];

printf("apub> ");

fflush(stdout);

while (!_shutdown)
{

if ( !fgets(input, sizeof(input), stdin) )
{
continue;

} else {
char *message;
unsigned int message_len;

input[strlen(input) - 1] = 0; /* Strip off the \n */

if (*input == '.' && input[1] == 0)
{
publisher_delete(_publisher);
_call_shutdown();
break;
}

message = strdup(input);
message_len = strlen(message);
publish(_publisher, "enp://yoyo.com/xyz",message,
    message_len,
    _publish_ack, NULL, (void *)message, 0);
return;
}
}
return;
}

main(int argc, char **argv)
{
unsigned short port = 7997;
char host[256];

if (argc < 2) _exit_usage();

if (*(argv[1]) == '0')
{
strcpy(host, "127.0.0.1");
} else {
strcpy(host, argv[1]);
}

if (argc > 2)
{
port = (unsigned short)atoi(argv[2]);
}

disp = pas_dispatcher_new(NULL);
if (disp == NULL) _exit_error("ディスパッチャーを作成できません");

publisher_new_a(disp, NULL, host, port, _open_ack, disp);

pas_dispatch(disp);

_shutdown = 1;

pas_dispatcher_delete(disp);

exit(0);
}

サブスクライバのコードサンプル

/*
 * Copyright 1997 by Sun Microsystems, Inc.
 * All rights reserved
 *
 * asub :非同期サブスクライバの例
 *
 * 構文 :
 * asub ホスト名 ポート番号
 */

#include <stdlib.h>
#include <stdio.h>

#include "pasdisp.h"
#include "subscriber.h"

static pas_dispatcher_t *disp = NULL;
static subscriber_t *_subscriber = NULL;
static subscription_t *_subscription = NULL;
static renl_t *_renl = NULL;

static void _exit_usage()
{
printf("\n使用法 :\nasub ホスト名 ポート番号\n");
exit(5);
}

static void _exit_error(const char *msg)
{
printf("%s\n", msg);
exit(1);
}

static void _subscribe_ack(void *arg, int rc, void *subscription)
{
(void)arg;

if (!rc)
{
_subscription = subscription;
printf("購読依頼に成功しました\n");
} else {
printf("購読依頼に失敗しました - 状態 %d\n", rc);
pas_shutdown(disp);
}
}

static void _unsubscribe_ack(void *arg, int rc, void *ignored)
{
(void *)ignored;
(void *)arg;

if (rc != 0)
{
printf("購読の中止に失敗しました - 状態 %d\n", rc);
}

subscriber_delete(_subscriber);
pas_shutdown(disp);
}

static int _handle_notify(void *arg, char *url, char *str, int len)
{
(void *)arg;
printf("[%s] %.*s\n", url, len, (str) ? str : "(null)");
return 0;
}

static void _open_ack(void *arg, int rc, void *enc)
{
_subscriber = (subscriber_t *)enc;

(void *)arg;
if (rc)
{
printf("状態 %d のため、サブスクライバの作成に失敗しました\n", rc);
pas_shutdown(disp);
return;
}

subscribe(_subscriber, "enp://yoyo.com/xyz",
   _handle_notify, NULL,
   _subscribe_ack, NULL);

return;
}

static void _unsubscribe(int sig)
{
(int)sig;
unsubscribe(_subscriber, _subscription, _unsubscribe_ack, NULL);
}

main(int argc, char **argv)
{
unsigned short port = 7997;
char host[256];

if (argc < 2) _exit_usage();
if (*(argv[1]) == '0')
{
strcpy(host, "127.0.0.1");
} else {
strcpy(host, argv[1]);
}
if (argc > 2)
{
port = (unsigned short)atoi(argv[2]);
}

disp = pas_dispatcher_new(NULL);
if (disp == NULL) _exit_error("ディスパッチャーを作成できません");

subscriber_new_a(disp, NULL, host, port, _open_ack, NULL);

pas_dispatch(disp);

pas_dispatcher_delete(disp);

exit(0);
}

信頼性の高いパブリッシャとサブスクライバ

これらのコーディング例では、信頼性の高い非同期パブリッシャおよびサブスクライバを確立します。

信頼性の高いパブリッシャのサンプル

/*
 * Copyright 2000 by Sun Microsystems, Inc.
 * All rights reserved
 *
 * rpub :簡単で *信頼性の高い* 連携動作する非同期パブリッシャ
 * rsub (信頼性の高いサブスクライバ) と組み合わせて
 * 使用するように設計されています。
 *
 * 構文 :
 * rpub ホスト名 ポート番号
 */

#include <stdlib.h>
#include <stdio.h>

#include "pasdisp.h"
#include "publisher.h"

static pas_dispatcher_t *disp = NULL;
static publisher_t *_publisher = NULL;
static int _shutdown = 0;
static renl_t *_renl;

static void _read_stdin();

static void _exit_usage()
{

printf("\n使用法 :\nrpub ホスト名 ポート番号\n");

exit(5);
}

static void _exit_error(const char *msg)
{
printf("%s\n", msg);
exit(1);
}

static void _call_shutdown()
{
_shutdown = 1;
pas_shutdown(disp);
}

static void _renl_create_cb(void *arg, int rc, void *ignored)
{
(void *)arg;
(void *)ignored;

if (!_publisher)
{
printf("RENL の作成に失敗しました - 状態 %d\n", rc);
_call_shutdown();
return;
}

_read_stdin();

return;
}

static void _publisher_new_cb(void *arg, int rc, void *enc)
{
_publisher = (publisher_t *)enc;

(void *)arg;

if (!_publisher)
{
printf("パブリッシャの作成に失敗しました - 状態 %d\n", rc);
_call_shutdown();
return;
}

renl_create_publisher(_publisher, "renl_id", NULL,
  _renl_create_cb,NULL);

return;
}

static void _recv_ack(void *arg, int rc, void *ignored)
{
(void *)ignored;

if (rc < 0)
{
printf("応答のタイムアウト\n");
} else if ( rc == 0) {
printf("応答を受信しました\n");
}
fflush (stdout);

_read_stdin();

free(arg);

return;
}

static void _read_stdin()
{
static char input[1024];

printf("rpub> ");
fflush(stdout);
while (!_shutdown)
{
if ( !fgets(input, sizeof(input), stdin) )
{
continue;
} else {
char *message;
unsigned int message_len;

input[strlen(input) - 1] = 0; /*\n を削除する*/

if (*input == '.' && input[1] == 0)
{
publisher_delete(_publisher);
_call_shutdown();
break;
}

message = strdup(input);
message_len = strlen(message);

/*タイムアウト時間 5 秒*/
publish(_publisher, "enp://yoyo.com/xyz",
 message, message_len,
 NULL, _recv_ack, message, 5000);

return;
}
}
return;
}

main(int argc, char **argv)
{
unsigned short port = 7997;
char host[256];

if (argc < 2) _exit_usage();
if (*(argv[1]) == '0')
{
strcpy(host, "127.0.0.1");
} else {
strcpy(host, argv[1]);
}
if (argc > 2)
{
port = (unsigned short)atoi(argv[2]);
}

disp = pas_dispatcher_new(NULL);
if (disp == NULL) _exit_error("ディスパッチャーを作成できません");

publisher_new_a(disp, NULL, host, port, _publisher_new_cb,
  NULL);

pas_dispatch(disp);

_shutdown = 1;

pas_dispatcher_delete(disp);

exit(0);
}

信頼性の高いサブスクライバのサンプル

/*
 * Copyright 1997 by Sun Microsystems, Inc.
 * All rights reserved
 *
 * rsub :非同期サブスクライバの例
 *
 * 構文 :
 * rsub ホスト名 ポート番号
 */

#include <stdlib.h>
#include <stdio.h>

#include "pasdisp.h"
#include "subscriber.h"

static pas_dispatcher_t *disp = NULL;
static subscriber_t *_subscriber = NULL;
static subscription_t *_subscription = NULL;
static renl_t *_renl = NULL;

static void _exit_usage()
{
printf("\n使用法 :\nrsub ホスト名 ポート番号\n");
exit(5);
}

static void _exit_error(const char *msg)
{
printf("%s\n", msg);
exit(1);
}

static void _subscribe_ack(void *arg, int rc, void *subscription)
{
(void)arg;

if (!rc)
{
_subscription = subscription;
printf("購読依頼に成功しました\n");
_renl = renl_create_subscriber(_subscription, "renl_id", NULL);
} else {
printf("購読依頼に失敗しました - 状態 %d\n", rc)
pas_shutdown(disp);
}
}

static void _unsubscribe_ack(void *arg, int rc, void *ignored)
{
(void *)ignored;
(void *)arg;

if (rc != 0)
{
printf("購読の中止に失敗しました - 状態 %d\n", rc);
}

subscriber_delete(_subscriber);
pas_shutdown(disp);
}

static int _handle_notify(void *arg, char *url, char *str, int len)
{
(void *)arg;
printf("[%s] %.*s\n", url, len, (str) ? str : "(null)");
return 0;
}

static void _open_ack(void *arg, int rc, void *enc)
{
_subscriber = (subscriber_t *)enc;

(void *)arg;
if (rc)
{
printf("状態 %d のため、サブスクライバの作成に失敗しました\n", rc);
pas_shutdown(disp);
return;
}

subscribe(_subscriber, "enp://yoyo.com/xyz",_handle_notify,
NULL,_subscribe_ack, NULL);

return;
}

static void _unsubscribe(int sig)
{
(int)sig;
unsubscribe(_subscriber, _subscription, _unsubscribe_ack, NULL);
}

main(int argc, char **argv)
{
unsigned short port = 7997;
char host[256];

if (argc < 2) _exit_usage();
if (*(argv[1]) == '0')
{
strcpy(host, "127.0.0.1");
} else {
strcpy(host, argv[1]);
}
if (argc > 2)
{
port = (unsigned short)atoi(argv[2]);

}

disp = pas_dispatcher_new(NULL);

if (disp == NULL) _exit_error("ディスパッチャーを作成できません");

subscriber_new_a(disp, NULL, host, port, _open_ack, NULL);

pas_dispatch(disp);

pas_dispatcher_delete(disp);

exit(0);

}