Come disabilitare temporaneamente un listener di messaggi

Question

Quale sarebbe un buon modo per disabilitare temporaneamente un listener di messaggi? Il problema che voglio risolvere è:

• messaggio A JMS viene ricevuto da un messaggio ascoltatore
• ottengo un errore quando si cerca di elaborare il messaggio.
• Attendo che il sistema si riattivi per poter elaborare il messaggio.
• Fino a quando il mio sistema non è pronto, non voglio altri messaggi, quindi ...
• ... Voglio disabilitare il listener dei messaggi.
• Il sistema è di nuovo pronto per l'elaborazione.
• Il messaggio non riuscito viene elaborato e il messaggio JMS viene riconosciuto.
• Abilita nuovamente il listener dei messaggi.

In questo momento, sto utilizzando Sun App Server. Ho disabilitato il listener dei messaggi impostandolo su null nel MessageConsumer e abilitato di nuovo usando setMessageListener (myOldMessageListener), ma dopo non ho più ricevuto alcun messaggio.

Answer 1

Cosa succede se non si ritorna dal metodo listener onMessage() finché il sistema non è pronto per elaborare nuovamente i messaggi? Ciò impedirà a JMS di recapitare un altro messaggio su quel consumatore.

Questo è l'equivalente asincrono di non chiamare receive() in un caso sincrono.

Non esiste un multi-threading per una determinata sessione JMS, quindi la pipeline dei messaggi viene mantenuta fino a quando non viene restituito il metodo onMessage().

Non ho familiarità con le implicazioni della chiamata dinamica a setMessageListener(). Javadoc dice there's undefined behavior se chiamato "quando i messaggi vengono consumati da un listener esistente o da un utente di sincronizzazione". Se chiami da onMessage(), sembra che tu stia colpendo quel caso indefinito.

Ci sono i metodi start/stop a livello di Connessione, se questo non è troppo granuloso per voi.

Answer 2

Mi sembra che i messaggi vengano recapitati, ma non succede nulla con loro perché non c'è nessun listener collegato. È passato un po 'di tempo da quando ho fatto qualcosa con JMS, ma non vuoi che il messaggio venga inviato alla coda di messaggi non recapitati o qualcosa del genere mentre correggi il sistema, quindi sposta nuovamente i messaggi sulla coda originale una volta che sei pronto per essere rielaborato?

Answer 3

In WebLogic è possibile impostare un numero massimo di tentativi, una coda di errore per gestire i messaggi che superano il limite massimo di tentativi e altri parametri. Non sono certo fuori di testa, ma potresti anche essere in grado di specificare un periodo di attesa. Tutto questo è a tua disposizione nella console di amministrazione. Guarderei l'amministratore per il provider JMS che hai e vedere se può fare qualcosa di simile.

Answer 4

Problema risolto da una soluzione alternativa che sostituisce il listener di messaggi con un ciclo receive(), ma sono ancora interessato a come disabilitare un listener di messaggi e abilitarlo di nuovo a breve.

Answer 5

In JBoss il seguente codice farà il trucco:

MBeanServer mbeanServer = MBeanServerLocator.locateJBoss(); 
    ObjectName objName = new ObjectName("jboss.j2ee:ear=MessageGateway.ear,jar=MessageGateway-EJB.jar,name=MessageSenderMDB,service=EJB3"); 
    JMSContainerInvokerMBean invoker = (JMSContainerInvokerMBean) MBeanProxy.get(JMSContainerInvokerMBean.class, objName, mbeanServer); 

    invoker.stop(); //Stop MDB 
    invoker.start(); //Start MDB 

Answer 6

penso che si può chiamare

messageConsumer.setMessageListener(null); 

all'interno della vostra implementazione MessageListener e pianificare l'attività di ristabilimento (per esempio in ScheduledExecutorService). Questa attività dovrebbe chiamare

connection.stop(); 
messageConsumer.setMessageListener(YOUR_NEW_LISTENER); 
connection.start(); 

e funzionerà. I metodi start() e stop() sono usati per riavviare gli structrues di consegna (non per la connessione TCP).

Leggi Javadoc https://docs.oracle.com/javaee/7/api/javax/jms/Connection.html#stop--

interrompe temporaneamente la consegna di una connessione di messaggi in arrivo. La consegna può essere riavviata utilizzando il metodo di avvio della connessione. Quando la connessione viene interrotta, la consegna a tutti i consumatori dei messaggi della connessione viene inibita: il blocco riceve sincrono e i messaggi non vengono recapitati ai listener dei messaggi.

Answer 7

Per temporaneamente ferma la consegna di una connessione di messaggi in arrivo è necessario utilizzare stop() metodo dal Connection interfaccia: https://docs.oracle.com/javaee/7/api/javax/jms/Connection.html#stop--

Ma non chiamatela connection.stop() da MessageListener perché secondo JMS spec. si otterrà deadlock o eccezione. Invece puoi chiamare connection.stop() da thread diversi, devi solo sincronizzare MessageListener e il thread che va a sospendere la connessione con la funzione connection.stop()