RabbitMQ: Nachrichten bleiben "Unbestätigten"

Eine Unbestätigte Meldung besagt, dass es gelesen wurde, indem Sie Ihre Verbraucher, aber der Verbraucher hat nie zurück gesendet, eine Bestätigung an den RabbitMQ-broker zu sagen, dass es fertig ist Verarbeitung.

Ich bin nicht allzu vertraut mit dem Spring-Framework-plugin, aber irgendwo (für den Verbraucher) werden Sie die Erklärung Ihrer Warteschlange, es könnte wie folgt Aussehen (entnommen aus http://www.rabbitmq.com/tutorials/tutorial-two-java.html):

channel.queueDeclare(queueName, ....)

dann Sie Ihre setup Verbraucher

bool ackMode = false;
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(queueName, ackMode, consumer);

ackMode oben ist ein boolean auf false setzen, wir sind ausdrücklich zu sagen, RabbitMQ, dass meine Verbraucher wird bestätigen können jede Nachricht gegeben ist. Wenn dieses flag auf true festgelegt war, dann würden Sie nicht sehen, die Unbestätigten zählen in RabbitMQ, sondern sobald ein Verbraucher hat die Nachricht Lesen ab (ich.e es wurde geliefert, um den Verbraucher zu entfernen, entfernen Sie es aus der Warteschlange).

Quittierung einer Nachricht, die Sie tun würde, so etwas wie dieses:

QueueingConsumer.Delivery delivery = consumer.nextDelivery();
//...do something with the message...
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); //the false flag is to do with multiple message acknowledgement

Wenn Sie post einige Ihrer Verbraucher-code, dann könnte ich vielleicht weiter helfen...aber in der Zwischenzeit werfen Sie einen Blick auf BlockingQueueConsumer speziell: der Konstruktor Sie werden sehen, dass Sie können die AcknowledgeMode und werfen Sie auch einen Blick auf die nextMessage() gibt eine Message-Objekt enthält eine Methode namens getDeliveryTag() dies gibt eine Lange, das ist die ID, die Sie senden möchten zurück auf die basicAck

InformationsquelleAutor kzhen