Queue-Größe in Spring AMQP-Java-client

Bin ich mit Spring amqp version 1.1 als mein java-client.
Ich habe eine Warteschlange, die rund 2000 Meldungen. Ich will einen service haben die Prüfungen dieser queue-Größe und und wenn es leer ist, sendet Sie eine Meldung "Alle Artikel verarbeitet".

Ich weiß nicht, wie man die aktuelle queue-Größe ? Bitte helfen Sie

Googelte ich und fand eine Klasse "RabbitBrokerAdmin" das war in früheren version 1.0.
Ich denke, es ist nicht vorhanden in 1.1 jetzt.

Alle Zeiger in immer aktuelle queue-Größe?

InformationsquelleAutor hellojava | 2012-07-12
  1. 16

    Also ich weiß, das ist ein wenig zu spät und eine Lösung wurde bereits gefunden, aber hier ist ein weiterer Weg, um zu sehen Nachricht zählt in Ihren Warteschlangen

    Diese Lösung setzt Voraus, dass Sie mit dem spring framework, rabbitmq und haben festgelegt, Ihre queues in Ihre application-config mit folgenden tags definiert

    <rabbit:queue>
<rabbit:admin>

    Die java-Klasse:

    public class QueueStatsProcessor {
    @Autowired
    private RabbitAdmin admin;
    @Autowired
    private List<Queue> rabbitQueues;

    public void getCounts(){
        Properties props;
        Integer messageCount;
        for(Queue queue : rabbitQueues){
            props = admin.getQueueProperties(queue.getName());
            messageCount = Integer.parseInt(props.get("QUEUE_MESSAGE_COUNT").toString());
            System.out.println(queue.getName() + " has " + messageCount + " messages");
        }
    }
}

    Kannst du auch diese Lösung verwenden, Lesen Sie die aktuellen Verbraucher angebracht, um die Warteschlange
    http://docs.spring.io/spring-amqp/docs/1.2.1.RELEASE/api/org/springframework/amqp/rabbit/core/RabbitAdmin.html#getQueueProperties(java.lang.String)

    • Danke, ich ll versuchen, dass als gut.
    • Das ist die viel bessere Antwort. Weit weniger hacky.
    InformationsquelleAutor Jesse
  2. 10

    Können Sie die RabbitAdmin Instanz, um die details aus der Warteschlange, wie folgt:

    @Resource RabbitAdmin admin;
...
protected int getQueueCount(final String name) {
    DeclareOk declareOk = admin.getRabbitTemplate().execute(new ChannelCallback<DeclareOk>() {
        public DeclareOk doInRabbit(Channel channel) throws Exception {
            return channel.queueDeclarePassive(name);
        }
    });
    return declareOk.getMessageCount();
}
    InformationsquelleAutor Dominic Messenger
Schreibe einen Kommentar