vendredi 24 avril 2015
Spring JMS Listener
Posted on 02:58 by verona
Hallo Leute.
Ich arbeite mich gerade in JMS mit Spring und ActiveMQ ein und habe ein paar Fragen:
Ich möchte eine Springapplikation programmieren die im ersten Schritt ein JMS Listener ist. Am ende möchte ich auf 2 Queues hören, jetzt reicht daweil eine.
Ich habe nun eine eigene JMS Config für Spring angelegt:
Der Java Code zu der Klasse MessageListenerImpl:
So weit so gut. Nun möchte ich das ganze mit einem jUnit Test testen und habe da vorgeschlagen bekommen ActiveMQ embeddet dazu zu verwenden. Also das ich aus ActiveMQ mir die Nachricht schicke. Leider stehe ich jetzt komplett auf der Leiter. Das ist das erste mal das ich mit JMS und ActiveMQ arbeite. Möchte mich darin fortbilden weil ich es bald brauchen werde.
LG und vielen Dank im voraus.
Ich arbeite mich gerade in JMS mit Spring und ActiveMQ ein und habe ein paar Fragen:
Ich möchte eine Springapplikation programmieren die im ersten Schritt ein JMS Listener ist. Am ende möchte ich auf 2 Queues hören, jetzt reicht daweil eine.
Ich habe nun eine eigene JMS Config für Spring angelegt:
Code:
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"
p:brokerURL="http://vmlocalhost:61616" />
<bean id="simpleMessageListener" class="com.example.MessageListenerImpl" />
<jms:listener-container container-type="default"
connection-factory="connectionFactory" acknowledge="auto">
<jms:listener destination="foo.bar" ref="simpleMessageListener"
method="onMessage" />
</jms:listener-container>
Java Code:
-
-
public class MessageListenerImpl implements MessageListener {
-
-
-
/** Logger initialization. **/
-
private static final Logger LOGGER = LoggerFactory.getLogger(MessageListenerImpl.class);
-
-
-
@Override
-
public void onMessage(Message message) {
-
try {
-
TextMessage msg = (TextMessage) message;
-
LOGGER.info("Empfangene Nachricht: {}", msg.getText());
-
} catch(JMSException e) {
-
LOGGER.error("JMS Exception", e);
-
}
-
}
-
-
-
}
So weit so gut. Nun möchte ich das ganze mit einem jUnit Test testen und habe da vorgeschlagen bekommen ActiveMQ embeddet dazu zu verwenden. Also das ich aus ActiveMQ mir die Nachricht schicke. Leider stehe ich jetzt komplett auf der Leiter. Das ist das erste mal das ich mit JMS und ActiveMQ arbeite. Möchte mich darin fortbilden weil ich es bald brauchen werde.
LG und vielen Dank im voraus.
Spring JMS Listener
Categories: Spring JMS Listener
Inscription à :
Publier les commentaires (Atom)
0 commentaires:
Enregistrer un commentaire