2012-01-25 2 views
0

Je voudrais créer un ActiveMQ MessageListener et le configurer en utilisant Spring. Je vais héberger l'auditeur dans Tomcat. Je ne sais pas si ce flux peut être fait? Si c'est le cas, comment? Client ---> Tomcat ---> ActiveMQ ----> Service (Application Java) ----> ActiveMQ ---> Tomcat ---> ClientActiveMq en combinaison avec Tomcat

Merci à l'avance!

+0

Veuillez voir cette question. J'ai exactement besoin de la même chose. http://stackoverflow.com/questions/19706788/jersey-rest-web-service-with-activemq-middleware-integration Merci pour votre temps. – Kumar

+0

Je n'utilise que le service Jersey Rest et non le cadre à ressorts. Je dois garder toutes les demandes de revenus dans une file d'attente, puis les transmettre à la ressource et obtenir le résultat. Le point principal est que le traitement de toutes les demandes http correctement. Merci – Kumar

Répondre

1

Oui, cela peut être fait. Jetez un oeil à la DefaultMessageListenerContainer. A l'intérieur de votre configuration Spring dans votre application web, vous pouvez alors:

<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    <property name="brokerURL" ref="brokerUrl" /> 
</bean> 

<bean id="container" 
    class="org.springframework.jms.listener.DefaultMessageListenerContainer"> 
    <property name="connectionFactory" ref="connectionFactory" /> 
    <property name="destination" ref="queue" /> 
    <property name="messageListener" ref="myMessageListener" /> 
    <property name="cacheLevelName" value="CACHE_CONSUMER" /> 
</bean> 

Où myMessageListener est une référence à votre MessageListener.

En ce qui concerne votre question sur ce que le flux ressemblerait, ce serait:

  • JMS Le client envoie un message à une file d'attente sur le courtier ActiveMQ
  • Le courtier ActiveMQ reçoit le message et le transmet à l'un des consommateurs écoutant cette file, dans ce cas notre MessageListener dans Tomcat
+0

que les données peuvent être répondues pour corriger la session du client? Donnez-moi plus d'informations – anhdv

+0

si vous voulez une réponse pour aller à la bonne session client, vous devrez configurer une file d'attente temporaire et la définir comme réponse à votre application client lorsque vous envoyez le message JMS. –

+0

Le client utilise un navigateur Web pour envoyer des données -> ActiveMQ-> Service-> ActiveMq-> Client? – anhdv

0

Oui. et j'ai un service qui résout ces données et puis envoie le résultat à ActiveMq, puis montre le résultat au client

+0

Anh Veuillez regarder ceci. Merci pour votre temps. http://stackoverflow.com/questions/19706788/jersey-rest-web-service-with-activemq-middleware-integration – Kumar

Questions connexes