Discussion :

[vijvij]

Bonjour,

existe-t-il un moyen de 'neutraliser' un MDB afin qu'il ne consomme plus les messages depuis l'application elle-même ?
(lorsque l'instance est hors d'état de tournée, cela permet de laisser les messages aux autres instance.

Merci pour toute réponse que vous pourrez m'apporter.

[sebastien.moratinos]

dans ton mdb tu créer un

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

boolean isOpen = true;

par exemple.
Tu consomme les messages si isOpen est à true.
Tu fais une méthode

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
 
public setIsOpen(boolean pIsOpen) {
    this.isOpen = pIsOpen;
}

qui sera apellé par l'appli web avec false en paramètre pour empêcher les messages.

Que tu sois avec un mdb ne change rien c'est du java classique

[cocoyot]

Si tu as plusieurs MDB qui écoute sur le même topic ou queue, peu importe ce que chacun fait avec le message. Ils le reçoivent tous de toute façon.

Bonjour,

existe-t-il un moyen de 'neutraliser' un MDB afin qu'il ne consomme plus les messages depuis l'application elle-même ?
(lorsque l'instance est hors d'état de tournée, cela permet de laisser les messages aux autres instance.

Merci pour toute réponse que vous pourrez m'apporter.

[k4b4l]

Bonjour,

existe-t-il un moyen de 'neutraliser' un MDB afin qu'il ne consomme plus les messages depuis l'application elle-même ?
(lorsque l'instance est hors d'état de tournée, cela permet de laisser les messages aux autres instance.

Merci pour toute réponse que vous pourrez m'apporter.

Si tu peux récupérer la connection associé à ton MDB, il sufft de faire un stop pour l'arrêter et un start pour que cela reprenne.

J'ai implémenter cette fonction en créant pour JONAS, un connecteur JCA vers WEBSPHERE MQ. A chaque instanciation d'un MDB, la méthode "endpointActivation" de ma classe qui implements "ResourceAdapter" est appelé et je garde une trace par composant de la liste des connections associés. Ainsi, via un composant JMX développer dans ce connecteur JCA, je peux stopper tous les MDB d'un type ou associé à un topic ou queue précise en récupérant la connection.

Dans ton descripteur d'ejb, il suffit de dire que tu utilise le jndiname de l'activation spec de ton connecteur.

Exemple:
jonas-ejb-jar.xml:

<jonas-message-driven-destination>
<jndi-name>jms/myActivationSpec</jndi-name>
</jonas-message-driven-destination>

Le connecteur:
ra.xml

<inbound-resourceadapter>
<messageadapter>
<messagelistener id="MessageListener">
<messagelistener-type>javax.jms.MessageListener</messagelistener-type>
<activationspec>
<activationspec-class>
com.blahblah.MQActivationSpecImpl</activationspec-class>
<required-config-property>
<config-property-name>destination</config-property-name>
</required-config-property>
<required-config-property>
<config-property-name>destinationType</config-property-name>
</required-config-property>
</activationspec>
</messagelistener>
</messageadapter>
</inbound-resourceadapter>

et dans jonas-ra.xml de ton connecteur JCA:

<jonas-activationspec>
<id>MessageListener</id>
<description>javax.jms.MessageListener</description>
<jndi-name>jms/myActivationSpec</jndi-name>
<defaultAS>false</defaultAS>
</jonas-activationspec>