// CosNotification チャネル ファクトリのオブジェクト参照を取得
CORBA::Object_var channel_factory_oref =
      bootstrap.resolve_initial_references(
        "NotificationService" );

CosNotifyChannelAdmin::EventChannelFactory_var
   channel_factory =
       CosNotifyChannelAdmin::EventChannelFactory::_narrow(
          channel_factory_oref.in() );

// チャネル ファクトリを使用してデフォルト チャネルを取得
CosNotifyChannelAdmin::EventChannel_var channel =
   channel_factory->get_event_channel(
       Tobj_Notification::DEFAULT_CHANNEL );

// イベントをポストする側なので、
// SupplierAdmin オブジェクトを取得する
CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin =
      channel->default_supplier_admin();

// サプライヤ管理を使用してプロキシを作成する。イベントはそのプロキシ
// にポストされる (シンプル イベント インタフェースの場合、イベント
// はチャネルにポストされる)
CosNotifyChannelAdmin::ProxyID proxy_id;
CosNotifyChannelAdmin::ProxyConsumer_var generic_proxy_consumer =
     supplier_admin->obtain_notification_push_consumer(
        CosNotifyChannelAdmin::STRUCTURED_EVENT, proxy_id );

CosNotifyChannelAdmin::StructuredProxyPushConsumer_var
   proxy_push_consumer =
     CosNotifyChannelAdmin::StructuredProxyPushConsumer::_narrow(
        generic_proxy_consumer );

// イベントをポストできるようにプロキシに接続
proxy_push_consumer->connect_structured_push_supplier(
      CosNotifyComm::StructuredPushSupplier::_nil() );

...
// イベントを作成
  CosNotification::StructuredEvent notification;

// ドメインを「News」に設定
notification.header.fixed_header.event_type.domain_name =
    CORBA::string_dup("News");

// 型をニュース カテゴリに設定
notification.header.fixed_header.event_type.type_name =
    CORBA::string_dup(“Sports”);

// 記事を格納するフィールドを 1 つイベントのフィルタ
// 処理可能データに追加。フィールドの名前は「Story」、
// 値は記事の文字列に設定
notification.filterable_data.length(1);
notification.filterable_data[0].name =
           CORBA::string_dup("Story");
notification.filterable_data[0].value <<= “John Smith wins again”;

// イベントをポスト
// ドメインが「News」で、型がニュース カテゴリと一致する
// イベントをサブスクライブしたサブスクライバがこのイベント
// を受信する

proxy_push_consumer->push_structured_event(notification);

...
// 接続を解除
proxy_push_consumer->disconnect_structured_push_consumer();

#ifndef _news_consumer_i_h
#define _news_consumer_i_h

#include "CosNotifyComm_s.h"

// サーバント クラスでニュース イベントを受信するためには、
// CosNotifyComm::StructuredPushConsumer idl インタフェース
// を実装する必要がある

class NewsConsumer_i : public POA_CosNotifyComm::StructuredPushConsumer

{
  public:

    // このメソッドはニュース イベントの発生時に呼び出される

    virtual void push_structured_event(
      const CosNotification::StructuredEvent& notification
    );

    // OMG の CosNotifyComm::StructuredPushConsumer idl インタフェース
    // では、offer_change メソッドと disconnect_structured_push_consumer
    // メソッドが定義される。ノーティフィケーション サービスからそれらの
    // メソッドが呼び出されることはないので、ただ単に CORBA::NO_IMPLEMENT
    // 例外を送出させる

    virtual void offer_change(
      const CosNotification::EventTypeSeq& added,
      const CosNotification::EventTypeSeq& removed )
    {
      throw CORBA::NO_IMPLEMENT();
    }

    virtual void disconnect_structured_push_consumer()
    {
      throw CORBA::NO_IMPLEMENT();
    }
};
#endif

#include "NewsConsumer_i.h"
#include <iostream.h>

//-----------------------------------------------------------
// Subscriber.cpp は「News」イベントのシンプル イベント 
// サブスクリプションを作成し、イベントが NewsConsumer_i オブジェクト
// に配信されるようにする。ニュース イベントが発生すると (ユーザが
// Reporter アプリケーションを実行してニュース記事を報告すると発生する)、
// 次のメソッドが呼び出される

void NewsConsumer_i::push_structured_event(
  const CosNotification::StructuredEvent& notification )
  {
// イベントのフィルタ処理可能データの最初のフィールドから
// 記事を抽出する
char* story;
notification.filterable_data[0].value >>= story;

// コードを単純化するために、「story」は「null」ではないと想定

// イベントを出力
cout
    << "-----------------------------------------------------"
    << endl
    << "Category : "
    << notification.header.fixed_header.
                           event_type.type_name.in()
    << endl
    << "Story    : "
    << story
    << endl;
...
}

// CosNotification チャネル ファクトリのオブジェクト参照を取得
CORBA::Object_var
  channel_factory_oref =
     bootstrap.resolve_initial_references(
          "NotificationService" );

CosNotifyChannelAdmin::EventChannelFactory_var
   channel_factory =
      CosNotifyChannelAdmin::EventChannelFactory::_narrow(
          channel_factory_oref.in() );

// チャネル ファクトリを使用してデフォルト チャネルを取得
CosNotifyChannelAdmin::EventChannel_var channel =
   channel_factory->get_event_channel(
      Tobj_Notification::DEFAULT_CHANNEL );

// チャネルを使用してコンシューマ管理とフィルタ ファクトリを取得
CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin =
    channel->default_consumer_admin();

CosNotifyFilter::FilterFactory_var filter_factory =
    channel->default_filter_factory();

// このクライアントではコールバックをサポートする必要があるので
// コールバック ラッパー オブジェクトを作成する
BEAWrapper::Callbacks wrapper(orb.in());

NewsConsumer_i* news_consumer_impl = new NewsConsumer_i;

// このサーバントの一時的なオブジェクト参照を作成
CORBA::Object_var news_consumer_oref =
       wrapper.start_transient(
         news_consumer_impl,
         CosNotifyComm::_tc_StructuredPushConsumer->id()
          );

CosNotifyComm::StructuredPushConsumer_var
    news_consumer =
       CosNotifyComm::StructuredPushConsumer::_narrow(
           news_consumer_oref.in() );

// 新しいサブスクリプションを作成 (この時点ではまだ完全ではない)
CosNotifyChannelAdmin::ProxyID subscription_id;
CosNotifyChannelAdmin::ProxySupplier_var generic_subscription =
      consumer_admin->obtain_notification_push_supplier(
          CosNotifyChannelAdmin::STRUCTURED_EVENT,
          subscription_id );

CosNotifyChannelAdmin::StructuredProxyPushSupplier_var
     subscription =
       CosNotifyChannelAdmin::StructuredProxyPushSupplier::_narrow(
            generic_subscription );
      s_subscription = subscription.in();

  // サービスの品質を設定する。これでサブスクリプション名
  // とサブスクリプションのタイプ (TRANSIENT) が設定される
CosNotification::QoSProperties qos;
  qos.length(2);
  qos[0].name =
      CORBA::string_dup(Tobj_Notification::SUBSCRIPTION_NAME);
  qos[0].value <<= subscription_name;
  qos[1].name =
     CORBA::string_dup(Tobj_Notification::SUBSCRIPTION_TYPE);
  qos[1].value <<=
     Tobj_Notification::TRANSIENT_SUBSCRIPTION;

  subscription->set_qos(qos);

  // フィルタを作成 (ドメイン、型、およびデータ フィルタの指定に使用)
CosNotifyFilter::Filter_var filter =
          filter_factory->create_filter(
            Tobj_Notification::CONSTRAINT_GRAMMAR );
  s_filter = filter.in();

    // フィルタ処理パラメータを設定
    // (ドメイン = "News"、型 = “Sports”、およびデータ フィルタなし)
    CosNotifyFilter::ConstraintExpSeq constraints;
    constraints.length(1);
    constraints[0].event_types.length(1);
    constraints[0].event_types[0].domain_name =
          CORBA::string_dup("News");
    constraints[0].event_types[0].type_name =
          CORBA::string_dup(“Sports”);
    constraints[0].constraint_expr = 
          CORBA::string_dup(""); // データ フィルタなし

    CosNotifyFilter::ConstraintInfoSeq_var
        add_constraints_results = // この戻り値は無視
            filter->add_constraints(constraints);

    // フィルタをサブスクリプションに追加
CosNotifyFilter::FilterID filter_id =
       subscription->add_filter(filter.in());

    // サブスクリプションの名前、タイプ、およびフィルタ処理の各パラメータ
    // が設定されたので、イベントを配信するコールバック オブジェクトの
    // オブジェクト参照を渡してサブスクリプションを完成する
    subscription->connect_structured_push_consumer(
         news_consumer.in() );

# idl コマンドを実行
idl -IC:\tuxdir\include C:\tuxdir\include\CosEventComm.idl \
C:\tuxdir\include\CosEventChannelAdmin \
C:\tuxdir\include\CosNotification.idl \
C:\tuxdir\include\CosNotifyComm.idl \
C:\tuxdir\include\CosNotifyFilter.idl \
C:\tuxdir\include\Tobj_Notification.idl

# buildobjclient コマンドを実行
buildobjclient -v -o is_reporter.exe -f ”\
    -DWIN32                              \
    Reporter.cpp                         \
    CosEventComm_c.cpp                   \
    CosEventChannelAdmin_c.cpp           \
    CosNotification_c.cpp                \
    CosNotifyComm_c.cpp                  \
    CosNotifyFilter_c.cpp                \
    CosNotifyChannelAdmin_c.cpp          \
    Tobj_Events_c.cpp                    \
    Tobj_Notification_c.cpp ”

# アプリケーションを実行
is_reporter

# idl コマンドを実行
idl -P -IC:\tuxdir\include C:\tuxdir\include\CosEventComm.idl \
C:\tuxdir\include\CosEventChannelAdmin \
C:\tuxdir\include\CosNotification.idl \
C:\tuxdir\include\CosNotifyComm.idl \
C:\tuxdir\include\CosNotifyFilter.idl \
C:\tuxdir\include\CosNotifyChannelAdmin \ \C:\tuxdir\include\Tobj_Events.idl \
\C:\tuxdir\include\Tobj_Notification

# buildobjclient コマンドを実行
buildobjclient -v -P -o is_subscriber.exe  -f " \
   -DWIN32                                      \
    Subscriber.cpp                               \
    NewsConsumer_i.cpp                           \
    CosEventComm_c.cpp                           \
    CosEventChannelAdmin_c.cpp                   \
    CosNotification_c.cpp                        \
    CosNotifyComm_c.cpp                          \
    CosNotifyComm_s.cpp                          \
    CosNotifyFilter_c.cpp                        \
    CosNotifyChannelAdmin_c.cpp                  \
    Tobj_Events_c.cpp                            \
    Tobj_Notification_c.cpp                      \
    C:\tuxdir\lib\libbeawrapper.lib              \
    "

# アプリケーションを実行
is_subscriber

# idl コマンドを実行
idl -P -I/usr/local/tuxdir/include /usr/local/tuxdir/include/CosEventChannelAdmin \
/usr/local/tuxdir/include/CosEventComm.idl \
/usr/local/tuxdir/include/CosNotification.idl \
/usr/local/tuxdir/include/CosNotifyComm.idl \
/usr/local/tuxdir/include/CosNotifyFilter.idl \
/usr/local/tuxdir/include/CosNotifyChannelAdmin \
/usr/local/tuxdir/include/Tobj_Events.idl \
/usr/local/tuxdir/include/Tobj_SimpleEvents.idl

# buildobjclient コマンドを実行
buildobjclient -v -P -o subscriber -f "     \
  Subscriber.cpp                            \
  NewsConsumer_i.cpp                        \
  CosEventComm_c.cpp                        \
  CosEventChannelAdmin_c.cpp                \
  CosNotification_c.cpp                     \
  CosNotifyComm_c.cpp                       \
  CosNotifyComm_s.cpp                       \
  CosNotifyFilter_c.cpp                     \
  CosNotifyChannelAdmin_c.cpp               \
  Tobj_Events_c.cpp                         \
  Tobj_SimpleEvents_c.cpp                   \
  -lbeawrapper                              \
"
# アプリケーションを実行
is_subscriber