spring jms acknowledge

slt

une question d'ordre général sur spring/jms

j'ai une appli spring qui communique entre ses modules via jms.
pour limiter le nombre de messages vers différents module, j'utilise un throttle. Celui ci me permet de contrôler exactement le nb de message sur un espace de temps donné. Disons que c'est un espèce de heartbeat . En effet le fait de jouer sur le nombre de consommateur de la queue n'est pas assez précis.

Donc mon throttle est appelé au début de la méthode onMessage() : si un jeton de temps est disponible, la méthode s'exécute sinon je lève une exception. Mon acknowledgement est en mode CLIENT_ACKNOWLEDGE. Avec ce système j'espérai que la levé d'exception forcerait JMS a ne pas appeler la méthode message.acknowledge() et donc que le message soit retenté à nouveau, mais ce n'est pas le cas : il est essayé une seule fois quoiqu'il se passe.

Donc questions :
- comment forcer jms à retenter le message ?
- sinon peut on utiliser un système pour limiter à un tempo précis (ce point est très important), l'arrivée des messages jms ?

J'ai fait quelques essais ....
Le truc c'est que tu ne dois pas faire un throw sur une exception et la catcher dans ton code même si ton IDE te demande de le faire (Ex: eclipse ) ...
De plus j'ai remarqué que le listener ne re traite le message qui a été abondonné à cause de l'exception qu'après redémarrage du listener ... ajoute donc ses quelques lignes à ton fichier de config spring pour qu'il le retraite tout de suite :

Code:

---

1 2 3 4 5 6 7 8

<bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="concurrentConsumers" value="5"/> <property name="connectionFactory" ref="connectionFactory" /> <property name="destination" ref="destination" /> <property name="sessionAcknowledgeModeName" value="CLIENT_ACKNOWLEDGE"/> <property name="transactionManager" ref="jmsTransactionManager" /> <property name="messageListener" ref="myAsynchJmsListener" /> </bean>

---

et :

Code:

---

1 2 3 4 5 6 7 8

<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager102"> <property name="connectionFactory"> <ref bean="connectionFactory"/> </property> <property name="pubSubDomain"> <value>false</value> </property> </bean>

---

cela ne fonctionne pas mieux chez moi de plus je suis en jms 1.1 et des propriétés type "pubSubDomain" n'existe pas.