Apache Camel avec IBM MQ

Le meilleur que j'ai pu obtenir est décrite ci-dessous, illustré comme un Printemps XML contexte de l'application qui lui-même héberge le CHAMEAU contexte et les itinéraires. Cet exemple fonctionne avec le natif IBM MQ JCA des ressources conforme à la carte v7.5, à dos de CHAMEAU 2.16, Spring core 4.2. J'ai déployé dans Glassfish, Weblogic, et JBoss EAP7 serveurs.

La complexité est liée à la gestion du flux de la MQ des rapports dont la philosophie est en conflit avec celle d'une plaine JMS de réponse à un message. Pour une explication détaillée, veuillez vous référer à La mise en œuvre de natif de websphere MQ avec la Morue Camel JMS composant

Cet exemple basé sur le CHAMEAU XML DSL est autonome et facile à tester.

Nous commençons avec le Printemps, & CAMEL déclarations:

<?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:util="http://www.springframework.org/schema/util" 
xmlns:context="http://www.springframework.org/schema/context" 
xmlns:camel="http://camel.apache.org/schema/spring"
xmlns:jee="http://www.springframework.org/schema/jee"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd   
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
    http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
    http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd">

Le CHAMEAU contexte suit avec 2 itinéraires de: MQ de JMS et JMS de la MQ, ici enchaînés pour former un pont pour faciliter les tests.

<camel:camelContext id="mqBridgeCtxt">
<camel:route id="mq2jms" autoStartup="true">

Bizarre: sur Weblogic, la seule façon d'obtenir (par exemple) 3 auditeurs est de faire respecter les 3 connexions (avec 3 Chameau:à partir de déclarations dans la séquence) avec max 1 session, sinon un MQ erreur s'ensuit: MQJCA1018: une Seule session par connexion est autorisée. Sur JBoss, vous pouvez régler simplement concurrentConsumers=...

  <camel:from uri="wmq:queue:TEST.Q1?concurrentConsumers=1&amp;disableReplyTo=true&amp;
        acknowledgementModeName=SESSION_TRANSACTED"/> 

Le désactiver disableReplyTo option ci-dessus garantit que les CHAMEAUX ne produira pas une réponse avant que nous puissions tester la MQ type de message à 1=Demande (réponse) ou 8=datagramme (à sens unique!). Le test et la réponse de la construction n'est pas illustré ici.

Puis d'appliquer les EIP pour InOnly sur la prochaine publication de la plaine JMS pour être cohérent avec l'Inbound MQ mode.

  <camel:setExchangePattern pattern="InOnly"/>
  <!-- camel:process ref="reference to your MQ message processing bean fits here" /-->
  <camel:to uri="ref:innerQueue" />
</camel:route>

Cela se termine le MQ-à-jms route; vient ensuite la jms-à-MQ route toujours dans le même CHAMEAU contexte:

<camel:route id="jms2mq"  autoStartup="true">
  <camel:from uri="ref:innerQueue" />
  <!-- remove inner message headers and properties to test without inbound side effects! -->
  <camel:removeHeaders pattern="*"/> 
  <camel:removeProperties pattern="*" />
  <!-- camel:process ref="reference to your MQ message preparation bean fits here" /-->

Maintenant vient la demande drapeau de la MQ CoD rapport doit être retourné par la destination distante. Nous appliquons également la MQ message de Datagramme type (valeur 8).

  <camel:setHeader headerName="JMS_IBM_Report_COD"><camel:simple resultType="java.lang.Integer">2048</camel:simple></camel:setHeader>
  <camel:setHeader headerName="JMS_IBM_Report_Pass_Correl_ID"><camel:simple resultType="java.lang.Integer">64</camel:simple></camel:setHeader>
  <camel:setHeader headerName="JMS_IBM_MsgType"><camel:simple resultType="java.lang.Integer">8</camel:simple></camel:setHeader>

Répondre à la file d'attente peut être spécifié via le ReplyTo uri option, l'autre comme un en-tête comme ci-dessous.

Ensuite, nous utilisons CamelJmsDestinationName en-tête pour faire respecter la suppression de la JMS MQ-tête de message MQRFH2 (à l'aide de targetClient MQ URL valeur de l'option 1). En d'autres termes, nous voulons envoyer un plain vanilla MQ message binaire (c'est à dire Uniquement le MQMD descripteur de message, suivie par la charge utile).

  <camel:setHeader headerName="JMSReplyTo"><camel:constant>TEST.REPLYTOQ</camel:constant></camel:setHeader>
  <camel:setHeader headerName="CamelJmsDestinationName"> <camel:constant>queue://MYQMGR/TEST.Q2?targetClient=1</camel:constant></camel:setHeader>

Plus MQMD des champs peut être contrôlé par le biais réservés JMS propriétés comme illustré ci-dessous. Voir les restrictions dans IBM doc.

  <camel:setHeader headerName="JMS_IBM_Format"><camel:constant>MQSTR   </camel:constant></camel:setHeader>
  <camel:setHeader headerName="JMSCorrelationID"><camel:constant>_PLACEHOLDER_24_CHARS_ID_</camel:constant></camel:setHeader>

La file d'attente de destination dans l'URI est remplacée par la CamelJmsDestinationName ci-dessus, d'où le nom de file d'attente dans l'URI devient un espace réservé.

L'URI option preserveMessageQos est celui qui - comme l'a observé le - permet d'envoyer un message avec le ReplyTo de données (pour obtenir la MQ CoD Rapport), mais ils les empêchent de CHAMEAU pour instancier un message de Réponse auditeur par l'application de la InOnly MEP.

  <camel:to uri="wmq:queue:PLACEHOLDER.Q.NAME?concurrentConsumers=1&amp;
            exchangePattern=InOnly&amp;preserveMessageQos=true&amp;
            includeSentJMSMessageID=true" />
</camel:route>
</camel:camelContext>

Nous n'avons pas fini, nous avons encore de déclarer notre file d'attente des usines pour les natifs fournisseur JMS et Websphere MQ (via le natif d'IBM WMQ JCA Adaptateur de Ressources), à adapter à votre contexte.
Nous utilisons ici JNDI des recherches sur des objets administratifs.

<camel:endpoint id="innerQueue" uri="jmsloc:queue:transitQueue">
</camel:endpoint>

<jee:jndi-lookup id="mqQCFBean" jndi-name="jms/MYQMGR_QCF"/>
<jee:jndi-lookup id="jmsraQCFBean" jndi-name="jms/jmsra_QCF"/>

<bean id="jmsloc" class="org.apache.camel.component.jms.JmsComponent">
  <property name="connectionFactory" ref="jmsraQCFBean" />
</bean>

<bean id="wmq" class="org.apache.camel.component.jms.JmsComponent">
  <property name="connectionFactory" ref="mqQCFBean" />
</bean>

</beans>

Une alternative à l'extraction de l'usine (et JCA adaptateurs) de JNDI est de déclarer le client JMS, comme le Printemps des haricots. Dans Weblogic et Glassfish, vous serez mieux inspiré en déployant le natif d'IBM JCA adaptateur de ressources et la création de ressources JNDI alors référencé dans le Ressort du Contexte que ci-dessus, dans JBoss direct MQ client bean déclaration convient le mieux en tant que ci-dessous)

<bean id="mqCFBean" class="com.ibm.mq.jms.MQXAConnectionFactory">
    <property name="hostName" value="${mqHost}"/>
    <property name="port" value="${mqPort}"/>
    <property name="queueManager" value="${mqQueueManager}"/>
    <property name="channel" value="${mqChannel}"/>
    <property name="transportType" value="1"/> <!-- This parameter is fixed and compulsory to work with pure MQI java libraries -->
    <property name="appName" value="${connectionName}"/>
</bean>

<bean id="wmq" class="org.apache.camel.component.jms.JmsComponent">
    <property name="connectionFactory" ref="mqCFBean"/>
    <property name="transacted" value="true"/>
    <property name="acknowledgementModeName" value="AUTO_ACKNOWLEDGE"/>
</bean>

Commentaires et améliorations bienvenues.

OriginalL'auteur berhauz

Un rapide google a révélé la suite,

http://lowry-techie.blogspot.de/2010/11/camel-integration-with-websphere-mq.html

HTH

OriginalL'auteur nabsha