我正計劃一個「消費者意識」服務,只有當該主題上至少有一個消費者時纔會處理某些類型的信息。使用Spring,我能夠創建下面的代碼來監控,當消費者連接或斷開由一個主題:使用ActiveMQ,可以強制代理重新發送建議消息?
@JmsListener(destination = "ActiveMQ.Advisory.Consumer.>")
public void processaConsumidorConectado(Message message){
System.out.println("Registrou um consumidor");
}
那如果以後我註冊這個話題發生,則效果很好。但是在我註冊這個聽衆之前,可能會發生這樣的情況,我已經在某個主題中擁有了一個消費者
有沒有辦法強制activeMQ發送一個話題的所有諮詢信息或類似的東西?
謝謝!我會在這裏測試和回覆 –
您可以發送一條測試消息到您的主題,並在此之前收聽'ActiveMQ.Advisory.NoConsumer.Topic.YourTopic',如果消息是非持久性的,並且如果沒有消費者連接,您將收到你的消息@ NoConsumers話題 –