Конфигурация Spring JMS очереди Consumer

Я пытаюсь запустить очень простое приложение для изучения Spring JMS + ActiveMQ. Я вижу, что мой Producer создает сообщение (sysout), но в моем Consumer ничего не появляется, и исключение не выдается. Я думаю, что здесь мне не хватает чего-то простого; будет очень признателен за любую помощь.

[ОТРЕДАКТИРОВАНО, СЛЕДУЮЩИЙ КОД РАБОТАЕТ]

Режиссер:

@Component
public class JmsMessageProducer
{
    @Autowired
    private JmsTemplate template;

    public void generateMessages() throws JMSException
    {
        template.send(new MessageCreator()
        {
            public Message createMessage(Session session) throws JMSException
            {
                System.out.println("sending..");
                TextMessage message = session.createTextMessage("this is a Producer created message!");
                return message;
            }
        });
    }
}

Потребитель:

@Component
public class JmsMessageConsumer implements MessageListener {
    @Override
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            TextMessage tm = (TextMessage) message;
            try {
                System.out.println("CONSUMER - received ["+tm.getText()+"]");
            }
            catch (Throwable th) {
                th.printStackTrace();
            }
        }
    }
}

Конфигурация производителя:

<context:component-scan base-package="mrpomario.springcore.jms"/> <!-- finds the JmsMessageProducer -->

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

<bean id="pomarioQueue" class="org.apache.activemq.command.ActiveMQQueue">
    <constructor-arg value="mrpomario.springcore.jms.queue"/>
</bean>

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="defaultDestination" ref="pomarioQueue"/>
</bean>

Конфигурация потребителя:

<jms:listener-container>
    <jms:listener ref="jmsMessageConsumer" method="onMessage" destination="mrpomario.springcore.jms.queue"/>
</jms:listener-container>

<bean id="pomarioQueue" class="org.apache.activemq.command.ActiveMQQueue">
    <constructor-arg value="mrpomario.springcore.jms.queue"/>
</bean>

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

<amq:broker id="broker" useJmx="false" persistent="false">
    <amq:transportConnectors>
        <amq:transportConnector uri="tcp://localhost:8082" />
    </amq:transportConnectors>
</amq:broker>

Прецедент:

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:mrpomario/springcore/jms/jms-config.xml")
public class JmsTest
{
    @Autowired
    JmsMessageProducer jmsMessageProducer;

    @Test
    public void test_Single_Queue_Producer_and_Consumer_Unidirectional() throws JMSException
    {
        try
        {
            jmsMessageProducer.generateMessages();
            assertTrue(true);
        }
        catch (Throwable th)
        {
            System.out.println("\n\nJmsTest: remote invocation failed. Ensure the web server is running.\n\n");
        }
    }
}

Я запускаю производителя внутри контейнера Java EE (mvn jetty:run), где также работает приложение Spring MVC.


person Community    schedule 25.09.2012    source источник


Ответы (1)


Я думаю, что вы в конечном итоге отправляете и потребляете от двух совершенно разных брокеров (и впоследствии разных очередей):

Определите своего брокера только в одном месте, скажем, в конфигурации вашего производителя:

<amq:broker id="broker" useJmx="false" persistent="false">
    <amq:transportConnectors>
        <amq:transportConnector uri="tcp://localhost:8082" />
        <amq:transportConnector uri="vm://localhost" />
    </amq:transportConnectors>
</amq:broker>

<amq:connectionFactory id="jmsFactory" brokerURL="vm://localhost" />

Из вашей конфигурации потребителя удалите конфигурацию брокера и используйте только connectionFactory: Либо (если вы находитесь в той же виртуальной машине):

<amq:connectionFactory id="jmsFactory" brokerURL="vm://localhost" />

Или (если удаленно):

<amq:connectionFactory id="jmsFactory" brokerURL="tcp://localhost:8082" />
person Biju Kunjummen    schedule 25.09.2012
comment
Привет Биджу, большое спасибо за ваш отзыв! Я попробовал новый макет конфигурации, который соответствует официальному учебнику Spring, но все еще не может заставить его работать (потребитель не вызывается). Не могли бы вы просмотреть его и дать мне отзыв? - person ; 25.09.2012
comment
Выглядит хорошо, можете ли вы подтвердить, используете ли вы производителя и потребителя в одной и той же виртуальной машине. - person Biju Kunjummen; 25.09.2012
comment
да, оба работают на одной виртуальной машине. Производитель работает с использованием JUnit, а Потребитель работает внутри встроенного сервера Jetty (начинается с mvn jetty:run). Может ли этот макет конфигурации вызывать у меня проблемы? - person ; 25.09.2012
comment
да я так думаю помарио, это скорее всего не тот ВМ - person Biju Kunjummen; 25.09.2012
comment
хм... как бы вы поступили, я имею в виду, что потребитель находится на одной виртуальной машине, а производитель - на другой? - person ; 25.09.2012
comment
Если вы хотите, чтобы потребитель был в одном, а производитель — в другом, это также просто с ActiveMQ, вам придется выставить ActiveMQ в качестве сервера — первая конфигурация брокера в моем ответе делает это..<amq:transportConnector uri="tcp://localhost:8082"/> и подключитесь от потребителя, также используя тот же адрес вместо vm://.. - person Biju Kunjummen; 25.09.2012
comment
Оно работает! :-) Последний вопрос, прежде чем я закончу, @Biju: почему мне нужно дважды определять URL-адрес потребителя, один в bean-компоненте connectionFactory, а затем дублировать тот же URL-адрес в bean-компоненте брокера? Смотрите мой код (я обновил его рабочей версией) - person ; 26.09.2012