確認消息到達隊列

Question

我使用org.hornetq.api.core.client

如何確認發送使用

producer.send("validQueue",clientMessage) 

是成功的，也達到了隊列中的消息？

試圖發送到無效的隊列即

producer.send("NoneExistingQueue",clientMessage) 

沒扔hornetQException如我所料。

Answer 1

有了核心API，我們允許用戶進行純粹的發佈訂閱。沒有註冊地址意味着你沒有人連接到特定地址（即不感興趣..在這種情況下，消息只是被忽略）

如果你需要這種語義，我建議你做我們在我們做的事情JMS實現，我們在這裏查詢現有的隊列。

如果您知道隊列的名字，我建議你做：

QueueQuery query = session.queueQuery(queueName); 

如果您不知道隊列的名字和你有純的pub/sub：

BindingQuery queryBinding = session.bindingQuery(SimpleString address) 

然後，如果沒有消費者，你可以對你的用例做適當的處理。