查詢Mule ESB VM隊列中的消息數

Question

在一個Mule流中，我想添加一個異常處理程序，它在發生異常時將消息轉發到「重試隊列」。但是，我不希望此重試邏輯自動運行。相反，我寧願收到通知，以便我可以查看錯誤，然後決定是否重試隊列中的所有消息。

我不想收到每個例外的通知。我寧願有一個每15分鐘運行一次的計劃作業，並檢查此重試隊列中是否有消息，然後只發送通知（如果有）。

有什麼方法可以確定當前有多少消息在持久的VM隊列中？

Answer 1

假設你使用默認的虛擬機隊列的持久性機制，而VM連接器被命名爲vmConnector，你可以這樣做：

final String queueName = "retryQueue"; 
int messageCount = 0; 

final VMConnector vmConnector = (VMConnector) muleContext.getRegistry() 
    .lookupConnector("vmConnector"); 

for (final Serializable key : vmConnector.getQueueProfile().getObjectStore().allKeys()) 
{ 
    final QueueKey queueKey = (QueueKey) key; 
    if (queueName.equals(queueKey.queueName)) 
    { 
     messageCount++; 
    } 
} 

System.out.printf("Queue %s has %d pending messages%n", queueName, messageCount);