Wie kann ich actievmq die Größe der Warteschlange von der "org.apache.activemq.command.Message" bekommen?

Question

Ich möchte send() -Methode der BrokerFilter-Klasse überschreiben.

Diese Methode hat zwei Parameter: ProducerBrokerExchange und Message.

Kann ich die Größe der Zielwarteschlange von diesen beiden Parametern abrufen?

Ich benutze activemq-all-5.13.2.jar.

Answer 1

Sie auf StatisticsBrokerPlugin verweisen.

Der Code ist hier, wenn jemand anderes benötigt.

ActiveMQDestination msgDest = messageSend.getDestination(); 
    String physicalName = msgDest.getPhysicalName(); 
    logger.info("dest: " + physicalName); 

    ActiveMQDestination queryDestination = ActiveMQDestination.createDestination(physicalName, msgDest.getDestinationType()); 
    Set<Destination> destinations = getDestinations(queryDestination); 
    logger.info(destinations); 
    long count = 0; 
    for (Destination dest : destinations) { 
     DestinationStatistics stats = dest.getDestinationStatistics(); 
     if (stats != null) { 
      count = stats.getMessageSize().getCount(); 
      logger.info("size: " + count); 
     } 
    } 

Answer 2

Sie verwenden können:

BrokerFilter.getRegionDestination().getDestinationStatistics().getMessages().getCount(); 

Sie dieses alle Statistiken haben in org.apache.activemq.broker.region.DestinationStatistics:

enqueues = new CountStatisticImpl("enqueues", "The number of messages that have been sent to the destination"); 
dispatched = new CountStatisticImpl("dispatched", "The number of messages that have been dispatched from the destination"); 
dequeues = new CountStatisticImpl("dequeues", "The number of messages that have been acknowledged from the destination"); 
forwards = new CountStatisticImpl("forwards", "The number of messages that have been forwarded to a networked broker from the destination"); 
inflight = new CountStatisticImpl("inflight", "The number of messages dispatched but awaiting acknowledgement"); 
expired = new CountStatisticImpl("expired", "The number of messages that have expired"); 

consumers = new CountStatisticImpl("consumers", "The number of consumers that that are subscribing to messages from the destination"); 
consumers.setDoReset(false); 
producers = new CountStatisticImpl("producers", "The number of producers that that are publishing messages to the destination"); 
producers.setDoReset(false); 
messages = new CountStatisticImpl("messages", "The number of messages that that are being held by the destination"); 
messages.setDoReset(false); 
messagesCached = new PollCountStatisticImpl("messagesCached", "The number of messages that are held in the destination's memory cache"); 
processTime = new TimeStatisticImpl("processTime", "information around length of time messages are held by a destination"); 
blockedSends = new CountStatisticImpl("blockedSends", "number of messages that have to wait for flow control"); 
blockedTime = new TimeStatisticImpl("blockedTime","amount of time messages are blocked for flow control"); 
messageSize = new SizeStatisticImpl("messageSize","Size of messages passing through the destination");