在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中創建偵聽器

回答

相關問題