Как реализовать локальную очередь JMS с использованием Spring 3.05 и JBoss 5.1 (JBossMQ)?

Question

Существует приложение на основе среды Spring 3.0.5, работающее на сервере JBoss 5.1.

Я пытался следовать этому руководству, но он использует брокер ActiveMQ вместо JBossMQ (брокер JBoss 5.1 по умолчанию).

Я уже установил очередь с именем MyQueue в конфигурации JBoss (destination-service.xml):

<mbean code="org.jboss.jms.server.destination.QueueService"
  name="jboss.messaging.destination:service=Queue,name=MyQueue"
  xmbean-dd="xmdesc/Queue-xmbean.xml">
  <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>
  <depends>jboss.messaging:service=PostOffice</depends>

Вы можете увидеть остальную часть моего конфига ниже. Что мне не хватает? Как я могу указать имя JNDI для очереди и фабрику соединений? А как насчет адреса сервера ([ConnectionFactory] Connector bisocket://localhost:4457)?

Моя конфигурация в applicationContext.xml выглядит следующим образом:

<bean id="connectionFactory" class="org.jboss.jms.server.connectionfactory.ConnectionFactory" />

<bean id="messageDestination" class="javax.jms.Queue" />

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="receiveTimeout" value="10000" />
</bean>

<bean id="springJmsProducer" class="myPackage.QueueProducer">
    <property name="destination" ref="messageDestination" />
    <property name="jmsTemplate" ref="jmsTemplate" />
</bean> 

<bean id="messageListener" class="myPackage.QueueConsumer" />

Мой продюсер:

 public class QueueProducer {

    private JmsTemplate jmsTemplate;

    private Queue queue;

    public void setConnectionFactory(ConnectionFactory cf) {
        this.jmsTemplate = new JmsTemplate(cf);
    }

    public void setQueue(Queue queue) {     
        this.queue = queue;
    }

    public void send(Object object) {
        this.jmsTemplate.send(this.queue, new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
              return session.createTextMessage("my text to send");
            }
        });
    }
}

Мой потребитель:

public class QueueConsumer implements MessageListener {

    @Override
    public void onMessage(Message message) {
        if (message instanceof TextMessage) {
            try {
                System.out.println(((TextMessage) message).getText());
            }catch (JMSException ex) {
                throw new RuntimeException(ex);
            }
        }
        else {
            throw new IllegalArgumentException("Message must be of type TextMessage");
        }

    }
}

Answer 1

То, что вы хотите, скорее всего jndiTemplate, Кроме того, вы не совсем проводка jmsTemplate бобы вместе правильно. Вот поэтапное объяснение того, что вам нужно в вашем контенте Spring applicationContext.

Вам нужно будет настроить jndiTemplate для внедрения JNDI-реализации JBoss:

<bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
    <property name="environment">
        <props>
            <prop key="java.naming.factory.initial">
                org.jnp.interfaces.NamingContextFactory
            </prop>
            <prop key="java.naming.provider.url">
                jnp://localhost:1099
            </prop>
            <prop key="java.naming.factory.url.pkgs">
                org.jboss.naming:org.jnp.interfaces
            </prop>
        </props>
    </property>
</bean>

Затем настройте ConnectionFactory так, чтобы он указывал на вышеуказанную конфигурацию JNDI:

<!-- spring JMS definition -->
<bean name="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate" ref="jndiTemplate"/>
    <property name="jndiName" value="ConnectionFactory" />
</bean>

Сконфигурируйте менеджер транзакций с помощью вышеупомянутой ConnectionFactory:

<bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>

Свяжите пункт назначения с jndiTemplate и jndiName:

<!-- jms destination already defined in jboss -->
<bean name="myQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate" ref="jndiTemplate"/>
    <property name="jndiName" value="queue/MyQueue" />
</bean>

Наконец, настройте сам jmsTemplate так, чтобы он указывал на ConnectionFactory, и вы готовы использовать JmsTemplate в своем коде:

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

Вы также хотите, чтобы конфигурация контейнера приемника сообщений выполнялась вашим потребителем. Замените "jmsexample.ExampleListener" на имя класса, который содержит ваш MessageListener:

<!-- this is the Message Driven POJO (MDP) -->
<bean id="messageListener" class="jmsexample.ExampleListener" />

<!-- and this is the message listener container -->
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="destination" ref="myQueue"/>
    <property name="messageListener" ref="messageListener" />
</bean>