在 TIBCO Rendezvous 中创建侦听器答案

【问题标题】：Creating a listener in TIBCO Rendezvous在 TIBCO Rendezvous 中创建侦听器
【发布时间】：2012-07-14 02:52:17
【问题描述】：

我正在尝试在 tibco 集合点中创建一个侦听器。我想听一个特定的主题。我知道它应该看起来像这样：

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

【问题讨论】：

标签： tibco

【解决方案1】：

你首先打开 Tibrv Tibrv.open(Tibrv.IMPL_NATIVE);

创建传输 TibrvTransport transport = new TibrvRvdTransport(service, network, daemon);

创建监听器 new TibrvListener(Tibrv.defaultQueue(), this, transport, subject, null);

如果你的监听器是“this”，你的类需要实现 TibrvMsgCallback

可以在 onMsg(TibrvListener listener, TibrvMsg msg) 方法中处理消息。

【讨论】：

非常非常感谢！这很有帮助！我唯一不明白的是我如何创建 TibrvMsgCallback
您没有创建 TibrvMsgCallback。您要处理 tibrv 消息的类需要实现该接口，以便您的类可以实现 onMsg() 方法。您的 Tibco 安装是否有示例，例如 TIBRV\src\examples\java？
啊，我明白了，所以我添加了一个工具，然后添加了 onMsg 方法。不，我根本没有例子，所以我基本上是在黑暗中编写一个程序:(
有什么地方可以得到这些例子吗？
我相信他们应该与 Tibco 安装一起出现。