L'incorporation de courtier ActiveMQ dans Spring-MVC Tomcat webapp

C'est la façon de le faire.

Hypothèses

1. Vous vous connectez à une destination distante sur http://destination-box:61616
2. Vous allez vous connecter à votre courtier local via VM transport, sur vm://localhost:7001
3. Vous avez à distance deux files d'attente que vous souhaitez pont: queue1 et queue2

Pré: les espaces de nommage

Vous devez déclarer les espaces de noms suivants:

xmlns:p="http://www.springframework.org/schema/p"
xmlns:jms="http://www.springframework.org/schema/jms"

1. Créer un courtier local:

<bean id="bridgedBroker" class="org.apache.activemq.broker.BrokerService"
 init-method="start" destroy-method="stop">
  <property name="brokerName" value="bridgedBroker"/>
  <property name="persistent" value="true"/>
  <property name="transportConnectorURIs"> 
    <value>vm://localhost:7001</value>
  </property>
  <property name="jmsBridgeConnectors">
    <bean class="org.apache.activemq.network.jms.JmsQueueConnector">
      <property name="outboundQueueConnectionFactory">
        <bean class="org.apache.activemq.ActiveMQConnectionFactory">
          <property name="brokerURL" 
           value="failover:(tcp://destination-box:61616)?maxReconnectDelay=10" />
        </bean>
      </property>
      <property name="outboundQueueBridges">
        <list>
          <bean class="org.apache.activemq.network.jms.OutboundQueueBridge">
            <constructor-arg value="queue1"/>
          </bean>
          <bean class="org.apache.activemq.network.jms.OutboundQueueBridge">
            <constructor-arg value="queue2"/>
          </bean>
        </list>
      </property>
    </bean>
  </property>
</bean>

De sorte que vous êtes à l'aide de la persistance, activé par une propriété, et un Configuration du Broker URI pour configurer réessayer comportement. Vous devez indiquer le nom de chaque file d'attente à distance vous souhaitez vous connecter dans la outboundBridgeQueues liste.

2. Créer broker de connexion usines

Celui-ci se connecte au-dessus d'un courtier:

<bean id="brokerConnectionFactory"
 class="org.apache.activemq.ActiveMQConnectionFactory"
 p:brokerURL="vm://localhost:7001" />

Puis l'envelopper avec un CachingConnectionFactory (presque toujours un bonne idée):

<bean id="cachingBrokerConnectionFactory"
 class="org.springframework.jms.connection.CachingConnectionFactory"
 p:targetConnectionFactory-ref="brokerConnectionFactory"
 p:sessionCacheSize="10" />

3. Créer des équivalents locaux de la télécommande destinations

Chaque destination, vous serez en train de parler à maintenant besoin d'une représentation locale:

<bean id="queue1destination" class="org.apache.activemq.command.ActiveMQQueue">
  <constructor-arg value="queue1" />
</bean>

<bean id="queue2destination" class="org.apache.activemq.command.ActiveMQQueue">
  <constructor-arg value="queue2" />
</bean>

4. Créer JMS modèles à être câblé dans les haricots

Je vais en faire un pour queue1 ici; queue2 est exactement le même processus:

<bean id="queue1JMSTemplate"
 class="org.springframework.jms.core.JmsTemplate"
 p:connectionFactory-ref="cachingBrokerConnectionFactory"
 p:defaultDestination-ref="queue1destination" />

5. Utiliser JMS modèle

Un exemple de code:

public class SendToQueue1
{
  @Autowired protected JmsTemplate queue1JMSTemplate; 

  public void sendMessage(final String message) throws JMSException
  {
    queue1JMSTemplate.send(new MessageCreator()
    {
      public Message createMessage(Session session) throws JMSException
      {
        return session.createTextMessage(message);
      }
    });
  }
}

Et vous avez terminé! Pas trop douloureux, mais il a fallu un certain temps pour le faire fonctionner. Espérons que cela aide les gens dans l'avenir; c'est un excellent moyen pour ajouter rapidement persistante de messagerie pour une petite application.

Remarque: ce n'est pas une bonne façon de câbler la classe. Vous seriez probablement passer dans un JMSTemplate de config, donc vous pouvez utiliser la définition d'une classe et d'un grillage en différents modèles pour différentes files d'attente. J'ai juste fait comme ceci pour la vitesse. Il suffit d'utiliser votre Printemps instinct 🙂