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

Tobj_SimpleEvents::ChannelFactory_var channel_factory =
  Tobj_SimpleEvents::ChannelFactory::_narrow(
                     channel_factory_oref.in());

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

#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;
...
}

// このクライアントではコールバックをサポートする必要があるので
// コールバック ラッパー オブジェクトを作成する

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()
       );

CosNotification::QoSProperties qos;
qos.length(1);
qos[0].name =
  CORBA::string_dup(Tobj_SimpleEvents::SUBSCRIPTION_TYPE);
qos[0].value <<= Tobj_SimpleEvents::PERSISTENT_SUBSCRIPTION;

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

Tobj_SimpleEvents::SubscriptionID sub_id =
 channel->subscribe(
    subscription_info.subscription_name(),
    "News", // ドメイン
    “Sports”, // 型
    “”,     // データ フィルタなし
    qos,
    news_consumer.in()
  )
); 

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

# buildobjclient コマンドを実行
buildobjclient -v -o subscriber.exe -f " \ 
    -DWIN32                              \
    Reporter.cpp                         \
    CosEventComm_c.cpp                   \
    CosNotification_c.cpp                \
    CosNotifyComm_c.cpp                  \
    Tobj_Events_c.cpp                    \
    Tobj_SimpleEvents_c.cpp               \
    " 

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

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

# buildobjclient コマンドを実行
buildobjclient -v -P -o subscriber.exe -f "  \
  -DWIN32                                    \
  Subscriber.cpp                             \
  NewsConsumer_i.cpp                         \
  CosEventComm_c.cpp                         \
  CosNotification_c.cpp                      \
  CosNotifyComm_c.cpp                        \
  CosNotifyComm_s.cpp                        \
  Tobj_Events_c.cpp                          \
  Tobj_SimpleEvents_c.cpp                      \  c:\tuxdir\lib\libbeawrapper.lib              \
"

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

# idl コマンドを実行
idl -P -I/usr/local/tuxdir/include /usr/local/tuxdir/include/CosEventComm.idl \
/usr/local/tuxdir/include/CosNotification.idl \
/usr/local/tuxdir/include/CosNotifyComm.idl \
/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                        \
  CosNotification_c.cpp                     \
  CosNotifyComm_c.cpp                       \
  CosNotifyComm_s.cpp                       \
  Tobj_Events_c.cpp                         \
  Tobj_SimpleEvents_c.cpp                   \
  -lbeawrapper                              \
"

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