Spring JMS Listener

[Maggot]

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:

    <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"
        p:brokerURL="vm://localhost: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>

Der Java Code zu der Klasse MessageListenerImpl:

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.

 

[Maggot]

Kann mir leider keiner helfen?

Lg