Запуск слушателя сообщений ActiveMQ в Tomcat? - PullRequest
Новая
       19

Запуск слушателя сообщений ActiveMQ в Tomcat?

2 голосов
/ 13 января 2011

Я создал ActiveMQ MessageListener и настроил его с помощью Spring.Я принимаю слушателя в Tomcat.Когда я запускаю веб-приложение (в котором есть только слушатель), должен ли слушатель автоматически запускаться?Или мне нужна дополнительная настройка?

Вот что у меня есть.Во-первых, обновил файл web.xml, чтобы позволить Spring самостоятельно настраиваться при запуске, 

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
    http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">

    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>

    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>/WEB-INF/classes/spring/applicationContext.xml</param-value>
    </context-param>

</web-app>

Затем я создал applicationContext.xml для настройки прослушивателя ActiveMQ, 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:amq="http://activemq.apache.org/schema/core"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-3.0.xsd">

    <context:annotation-config />
    <context:component-scan base-package="com.somepackage"/>

    <context:property-placeholder location="classpath:env.properties"/>

    <bean id="jmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616" />
    </bean>

    <bean id="documentListener" class="com.somepackage.SomeListener" />

    <bean id="container"
        class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="cachingConnectionFactory"/>
        <property name="messageListener" ref="documentListener"/>
        <property name="destinationName" value="STOCKS.MSFT" />
    </bean>

    <bean id="cachingConnectionFactory"
        class="org.springframework.jms.connection.CachingConnectionFactory">
        <property name="targetConnectionFactory" ref="jmsFactory" />
        <property name="sessionCacheSize" value="1" />
    </bean>
</beans>

,Основываясь на том, что я видел в Интернете, я не могу сказать, все ли это мне нужно?Может быть, мне нужна другая конфигурация в Tomcat, чтобы запустить слушателя?

1 Ответ

1 голос
/ 13 января 2011

Это на самом деле работает.Я отлаживал это с помощью Eclipse, и мне пришлось сделать пару обновлений, очистить и перезапустить, прежде чем он вдруг решил работать.

Чтобы ответить на мой собственный вопрос, да, это все, что требуется для запускаслушатель в веб-приложении из Tomcat.Он может быть полностью настроен только на XML.

...