뮬 ESB VM 큐의 메시지 수에 대한 쿼리

Question

뮬 플로우에서 예외가있을 때 메시지를 "재시도 대기열"에 전달하는 예외 처리기를 추가하고 싶습니다. 그러나이 재시도 논리가 자동으로 실행되는 것을 원하지 않습니다. 대신 오류를 검토하고 큐에있는 모든 메시지를 다시 시도할지 여부를 결정할 수 있도록 알림을받습니다.

모든 예외에 대한 알림을 받고 싶지 않습니다. 차라리 15 분마다 실행되는 예약 된 작업을 수행하고이 재시도 대기열에 메시지가 있는지 확인한 다음 알림 만 보내면됩니다.

얼마나 많은 메시지가 현재 영구 VM 대기열에 있는지 확인할 수있는 방법이 있습니까?

Answer 1

기본 VM 큐 지속성 메커니즘을 사용하여 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);