Compter le nombre de messages dans une file d'attente JMS

Quelle est la meilleure façon d'aller sur une file d'attente JMS et obtenir tous les messages?

Comment pouvez compter le nombre de messages dans une file d'attente?

Grâce.

Vous pouvez utiliser jmx dans certains cas (en fonction de JMS mise en œuvre)
je vois, activemq tag. Exemple pour ActiveMQ java.dzone.com/articles/managing-activemq-jmx-apis

OriginalL'auteur Michael A | 2012-11-28

  1. 11

    À L'Aide De JmsTemplate

    public int getMessageCount(String messageSelector)
{
    return jmsTemplate.browseSelected(messageSelector, new BrowserCallback<Integer>() {
        @Override
        public Integer doInJms(Session s, QueueBrowser qb) throws JMSException
        {
            return Collections.list(qb.getEnumeration()).size();
        }
    });
}
    Par souci d'exhaustivité: c'est pour les utilisateurs du framework Spring.

    OriginalL'auteur Aaron G.

  2. 6

    C'est comment vous pouvez compter Pas de Messages dans une File d'attente

    public static void main(String[] args) throws Exception
    {
        //get the initial context
        InitialContext ctx = new InitialContext();

        //lookup the queue object
        Queue queue = (Queue) ctx.lookup("queue/queue0");

        //lookup the queue connection factory
        QueueConnectionFactory connFactory = (QueueConnectionFactory) ctx.
            lookup("queue/connectionFactory");

        //create a queue connection
        QueueConnection queueConn = connFactory.createQueueConnection();

        //create a queue session
        QueueSession queueSession = queueConn.createQueueSession(false,
            Session.AUTO_ACKNOWLEDGE);

        //create a queue browser
        QueueBrowser queueBrowser = queueSession.createBrowser(queue);

        //start the connection
        queueConn.start();

        //browse the messages
        Enumeration e = queueBrowser.getEnumeration();
        int numMsgs = 0;

        //count number of messages
        while (e.hasMoreElements()) {
            Message message = (Message) e.nextElement();
            numMsgs++;
        }

        System.out.println(queue + " has " + numMsgs + " messages");

        //close the queue connection
        queueConn.close();
    }
    J'ai effectivement couru cet exemple et pour une raison quelconque, le messeage compter montre de 400 lorsque j'ai 5000 messeages sur la file d'attente
    comment voulez-vous dire que vous avez 5000 messages dans une file d'attente.
    Je le vois physiclly sur mon ActiveMQ console
    vous l'envoyez dans une seule exécution ou plusieurs fois , Si éprouvée par plusieurs fois ActiveMQ était en cours d'exécution ou non pendant que vous vérifiez.
    En ce qui concerne votre récepteur ?

    OriginalL'auteur sunleo