1

私はtibcorendezvousでリスナーを作成しようとしています。特定のテーマについて聞きたいです。私はそれがこのように見えることになっていることを知っています：

TibrvListener(
TibrvQueue queue,
TibrvMsgCallback callback,
TibrvTransport transport,
java.lang.String subject,
java.lang.Object closure)
throws TibrvException

私はこのコードを持っています。しかし、私はいくつかのことを知りません。TibrvMsgCallbackオブジェクトを作成するにはどうすればよいですか？どうすれば交通機関を通過できますか？別のプログラムとしてメッセージを送信する発行元があります。サブスクライブプログラムで同じトランスポートを再作成しますか？

queue = new TibrvQueue();
dispatcher = new TibrvDispatcher(queue);
queue.setName(key);
this.listener = new TibrvListener(queue, null, null, subject, null);
TibrvTransport message = this.listener.getTransport();
4

1 に答える 1

3

最初にTibrvTibrv.open（Tibrv.IMPL_NATIVE）;を開きます。

トランスポートの作成TibrvTransporttransport= new TibrvRvdTransport（service、network、daemon）;

リスナーを作成しますnewTibrvListener（Tibrv.defaultQueue（）、this、transport、subject、null）;

リスナーが「this」の場合、クラスはTibrvMsgCallbackを実装する必要があります

メッセージは、onMsg（TibrvListenerリスナー、TibrvMsg msg）メソッドで到着時に処理できます。

于 2012-07-13T18:49:04.997 に答える