在TIBCO Rendezvous中创建侦听器

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

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

来源

2012-07-13 Lemonio

你第一次打开Tibrv Tibrv.open（Tibrv.IMPL_NATIVE）;

创建传输 TibrvTransport transport = new TibrvRvdTransport（service，network，daemon）;

创建监听器 new TibrvListener（Tibrv.defaultQueue（），this，transport，subject，null）;

如果你的听众是“本”，你的类需要实现TibrvMsgCallback

消息可以在onMsg到来处理（TibrvListener监听器，TibrvMsg味精）方法。

来源

2012-07-13 18:49:04 aditya

非常感谢你！这非常有帮助！唯一我仍然不明白的是我如何创建TibrvMsgCallback – Lemonio 2012-07-13 18:53:27

您不创建TibrvMsgCallback。您想要处理tibrv消息的类需要实现该接口，以便您的类可以实现onMsg（）方法。您的Tibco安装是否有例如TIBRV \ src \ examples \ java中的示例？ – aditya 2012-07-13 18:57:03

啊我看到所以我添加一个实现，然后onMsg方法。 nope我没有任何例子，所以我试图写一个程序基本上在黑暗中:( – Lemonio 2012-07-13 19:00:45

在TIBCO Rendezvous中创建侦听器

回答

相关问题