Warum kommt die Nachricht wieder zur onMessage() Funktion?

Question

Ich verwende ActiveMQ, um die Nachricht zu senden.

Also, wenn ich eine Nachricht gesendet habe, kommt Nachricht, um Nachricht zu erhalten. Bei erfolgreichem Einfügen wird es bestätigt.

Aber ich habe einen Code nach der Bestätigung, die NullPointerException werfen kann.

Um diese Ausnahme absichtlich zu erzeugen, habe ich NullPointerException werfen. So wenn ich das tue

Nachricht ist nicht dequeued und die gleiche Meldung kommt wieder auf die onMessage Funktion.

mein Code:

public void onMessage(Message message) { 
    String msg = null; 
    try 
    { 
     msg = receiveMessage(message); 

     // other code to insert message in db 

     message.acknowledge(); 

     if(true) 
     { 
     throw new NullPointerException("npe")); 
     } 
     ** // other code which might produces null pointer exception ** 
     } 
     catch(Exception ex){} 
    } 

Nun meine Frage ist, warum die Nachricht wieder zu onMessage() Funktion kommen, wie ich acknowledge() es auch haben.

Da habe ich bereits die Nachricht in db eingefügt.

Wird die Nachricht innerhalb der Warteschlange nicht unter acknowledge() entfernt?

Wie kann ich das erreichen? Vielen Dank im Voraus.

Answer 1

Sie können eine separate Methode für die Verarbeitung der Nachricht erstellen, mit der ich meine, dass in onMessage() Funktion schreiben Sie einen Code für nur Einfügen dieser Nachricht in DB.

Und erstellen Sie eine separate Funktion für die Verarbeitung dieser Nachricht. Wenn Sie während der Verarbeitung einen Fehler erhalten, wird die Nachricht nicht erneut an onMessage().

gesendet.

Answer 2

Wenn Sie einen Transaktions-JMS-Bestätigungsmodus verwenden, wird Ihre Nachricht mehrmals vom JMS-Listener empfangen (in AMQ ist standardmäßig ~ 8) bis sie ohne Ausnahme verarbeitet wird oder vom JMS-Container in die DQL-Warteschlange verschoben wird. Einzelheiten finden Sie unter Message Redelivery and DLQ Handling.

Die Verwaltung von Transaktionen hängt von dem von Ihnen verwendeten Framework ab. Ich ziehe es Frühling zu verwenden, so dass mein Spring-XML-config sieht aus wie

<jms:listener-container container-type="default" connection-factory="calendarConnectionFactory" 
         acknowledge="transacted" destination-type="queue" cache="consumer" concurrency="1-5"> 
    <jms:listener destination="${jms.calendar.destination}" ref="calendarListener"/> 
</jms:listener-container> 

und der Java-Code meiner Nachricht Hörer ist

@Override 
@Transactional(propagation = Propagation.REQUIRED, 
     noRollbackFor = {ClassCastException.class, IllegalArgumentException.class}) 
public void onMessage(Message message) { 
.... 
} 

So kann ich festlegen, welche Ausnahmen die Transaktion Rollback oder nicht

Answer 3

Sie verwenden den AUTO-Bestätigungsmodus mit Nachrichtenlistenern. Anschließend wird eine Nachricht erneut gesendet, wenn die Nachrichten-Listener nicht erfolgreich zurückgegeben werden können (z. B. wenn eine Ausnahme ausgelöst wird).

In Ihrem Fall versuchen Sie manuell die Nachricht zu bestätigen, aber das ist nicht möglich, mit createSession(false, Session.AUTO_ACKNOWLEDGE) einer Sitzung erstellt.

Ihr Code hätte mit Session.CLIENT_ACKNOWLEDGE funktioniert.

Andernfalls möchten Sie die Ausnahmen in der onMessage-Methode abfangen, während Sie AUTO_ACKNOWLEDGE verwenden.

Um eine detailliertere Kontrolle über Ihre Nachrichten zu erhalten, sollten Sie transaktierte Sitzungen verwenden und session.commit(); verwenden, um zu bestätigen, dass eine Nachricht gelesen wurde.

Answer 4

Haben Sie überprüft, dass Sie nicht transacted sessions verwenden?.Wenn getätigten Sitzungen verwendet wird, wird der Bestätigungsmodus ignoriert, so:

• Ihre message.acknowledge() effektiv ein

  no-op wäre würde

• Ihre abgefangene Ausnahme ein „Session-Rollback“ auslösen werden, wenn Ihre Nachricht Hörer Flucht , Erzwingen der Neuzustellung der Nachricht.

ANMERKUNG: Sie veröffentlichte Code hat ein catch (Exception ex) { }, so dass ich weiß nicht genau, wie Sie Ihre Ausnahme außerhalb entweicht.