Erste Zählung der Nachrichten in einem rabbitmq Warteschlange von java-code

Ich versuche, um zu überprüfen, ob eine gegebene rabbitmq Warteschlange leer ist oder nicht.
Für die, die ich versuche zu verwenden:

channel.queueDeclarePassive(queueName).getMessageCount().

Mit diesem bin ich immer 0 als Antwort, unabhängig von der Anzahl der angezeigten Nachrichten durch rabbitmqctl list_queues.
Es gibt keine API zur Verfügung, soweit ich gesucht habe.

Möchte ich gleich beantworten, wie rabbitmqctl list_queues.Sie schlagen einen Weg, das zu tun.

  • Versuchen channel.queueDeclare statt
  • Habe versucht, mit diesem auch.. kein Glück.. immer noch die 0 als Antwort..
InformationsquelleAutor user3184719 | 2014-02-19
  1. 5

    erhalten Sie keine Nachrichten zählen, die das SDK verwenden. Kanal.queueDeclarePassive(queueName).getMessageCount() ist in der Regel nicht korrekt, weil es nicht zählen Nachrichten, die darauf warten anerkennt.

    aktivieren Sie den Verwaltungs-Plug-ins und die Abfrage der queue-REST-API: 

    http://localhost:15672/api/queues/vhost/queue_name

    Die Antwort enthält die Gesamtzahl der Nachrichten zählen ebenso wie Nachrichten in der Handhabung/Status "bereit".
    Der Zugriff auf "localhost:15672/api" sehen Sie mehr Details darüber, wie Sie es nennen.

    Hier ist ein Beispiel einer Antwort auf lokale server:

    {
    "memory":14680,
    "message_stats":{
        "publish":1,
        "publish_details":{
            "rate":0
        }
    },
    "messages":1,
    "messages_details":{
        "rate":0
    },
    "messages_ready":1,
    "messages_ready_details":{
        "rate":0
    },
    "messages_unacknowledged":0,
    "messages_unacknowledged_details":{
        "rate":0
    },
    "idle_since":"2014-02-21 18:01:54",
    "policy":"",
    "exclusive_consumer_tag":"",
    "consumers":0,
    "backing_queue_status":{
        "q1":0,
        "q2":0,
        "delta":[
            "delta",
            0,
            0,
            0
        ],
        "q3":0,
        "q4":1,
        "len":1,
        "pending_acks":0,
        "target_ram_count":"infinity",
        "ram_msg_count":1,
        "ram_ack_count":0,
        "next_seq_id":1,
        "persistent_count":0,
        "avg_ingress_rate":0,
        "avg_egress_rate":0,
        "avg_ack_ingress_rate":0,
        "avg_ack_egress_rate":0
    },
    "status":"running",
    "name":"01d99c41-7e08-4122-a7f3-c57d25a460f5",
    "vhost":"/",
    "durable":true,
    "auto_delete":false,
    "arguments":{
    },
    "node":"rabbit@SHACNG109WQPY"
}
    • Danke @junius, es ist wirklich hilfreich.
    • Ich bin versucht, dies zu tun, aber es funktioniert nicht für mich. 🙁 Ich öffnen kann ../api , die auch ../api/Warteschlangen , aber ../api/queues/vhost und ../api/queues/vhost/queue_name nicht. Wissen Sie, was kann ich versuchen, diese Arbeit zu machen? Sie erwähnten , Sie können die management-plugin", was sein bedeutet? Danke!
    • http://localhost:15672/api/queues/%2f/hello - wo 'Hallo' queue-Namen, und '/' - vhost-name
    InformationsquelleAutor Junius
  2. 0

    Verwenden Sie folgende url für den Zugriff auf Daten per http-api,

    http://public-domain-name:15672/api/queues/%2f/queue_name

    oder verwenden Sie folgenden Befehl aus localhost cli promt,

    curl -i -u guest_uname:guest_password http://localhost:15672/api/queues/%2f/queue_name

    Wo,
    "%2f " ist default-vhost "/"

    InformationsquelleAutor Hemant Thorat
Schreibe einen Kommentar