Отправка сообщения amqp ibm mq - PullRequest
Новая
       13

Отправка сообщения amqp ibm mq

0 голосов
/ 08 апреля 2019

Попытка передачи сообщений из RabbitMQ <int-amqp:inbound-channel-adapter в MQSeries <int-jms:outbound-channel-adapter.Это прекрасно работает.

На самом деле некоторые производители в MQSeries используют такие классы IBM JMS: 

MQMessage messageMQ = new MQMessage();
messageMQ.format = "        ";
messageMQ.persistence = 1;
messageMQ.correlationId = MQ_MESSAGE_CORRELATION_ID;
messageMQ.write(message.getMessageData());
MQPutMessageOptions putMessageOption = new MQPutMessageOptions();
putMessageOption.options = 8194;
MQQueue queue = openQueue(destinataire, 8208);
queue.put(messageMQ, putMessageOption);

Я пытался использовать преобразователь между amqp и jms следующим образом: 

<int:transformer id="testTransformer" ref="testTransformerBean" input-channel="fromRabbit"
         method="transform" output-channel="toJms"/>


public MQMessage transform(Message<?> msg) throws Exception {

    MQMessage result = new MQMessage();
    result.format = "        ";
    result.persistence = 1;
    result.correlationId = MQC.MQCI_NONE;

    String test = "message to send ";
    result.write(test.getBytes());
    return result;
}

Каков тип хранения объектов в msg.getPayload ()?Как я могу преобразовать его в объект String?

При реализации этого метода у меня есть исключение, потому что исходящему требуется сообщение JMS, а не com.ibm.mq.MQMessage!

Cannot convert object of type [com.ibm.mq.MQMessage] to JMS message

Правильно ли это?

Или я должен удалить исходящий канал и использовать вместо этого активатор службы с определенным кодом для IBM?

Спасибо за вашу помощь

С уважением

Редактировать после ответа Артема

После исходящей конфигурации jms: 

<bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQConnectionFactory">
    <property name="queueManager" value="${queueManager}" />
    <property name="hostName" value="${hostName}" />
    <property name="port" value="${port}" />
    <property name="channel" value="${channelName}" />
    <property name="transportType" value="1" />
</bean>
<bean id="jmsQueue" class="com.ibm.mq.jms.MQQueue" depends-on="jmsConnectionFactory">
    <property name="baseQueueManagerName" value="${queueManager}" />
    <property name="baseQueueName" value="${queueName}" />
    <property name="targetClient" value="1" />
</bean>
<bean id="jmsConnectionFactory_cred"
    class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
    <property name="targetConnectionFactory" ref="jmsConnectionFactory" />
    <property name="username" value="${user}"/> 
    <property name="password" value="${password}"/> 
</bean> 

<bean id="connectionFactoryCaching"
    class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="jmsConnectionFactory_cred" />
    <property name="sessionCacheSize" value="${BRIDGE_MQ_OUTBOUND_SESSION_CACHE}" />
</bean>

<bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice" id="requestHandler">
    <property name="trapException" value="false"/>
    <property name="onFailureExpressionString" value="#this"/>
    <property name="failureChannel" ref="processChannel1"/>
</bean>

<int-jms:outbound-channel-adapter   channel="channelRmqMQ" 
                                    id="jmsOut" destination="jmsQueue" connection-factory="connectionFactoryCaching" delivery-persistent="true" 
                                    explicit-qos-enabled="true" session-transacted="true" >
    <int-jms:request-handler-advice-chain>
        <ref bean="requestHandler" />
    </int-jms:request-handler-advice-chain>                                         
</int-jms:outbound-channel-adapter>

1 Ответ

0 голосов
/ 08 апреля 2019

Если ваше сообщение AMQP идет с text/* contentType, то его тело автоматически конвертируется в строку с помощью SimpleMessageConverter в AmqpInboundChannelAdapter: 

     if (contentType != null && contentType.startsWith("text")) {
            String encoding = properties.getContentEncoding();
            if (encoding == null) {
                encoding = this.defaultCharset;
            }

            try {
                content = new String(message.getBody(), encoding);
            } catch (UnsupportedEncodingException var8) {
                throw new MessageConversionException("failed to convert text-based Message content", var8);
            }

В противном случае вам нужно поместить простой преобразователь между ними, чтобы преобразовать byte[] в строку: 

<object-to-string-transformer>

<int-jms:outbound-channel-adapter> как раз для взаимодействия с протоколом JMS, поэтому ваш MQMessage не будет принят там. Вот почему вы получаете это Cannot convert object of type [com.ibm.mq.MQMessage] to JMS message исключение.

Да, вы можете использовать IBM MP API напрямую в некоторых пользовательских service-activator, однако я бы посоветовал взглянуть на мост JMS-MQ в IBM WebSphere. Тогда вам нужно только настроить соответствующую фабрику соединений и использовать ее из <int-jms:outbound-channel-adapter>: 

<jee:jndi-lookup id="jndiMqConnectionFactory" jndi-name="${mqConnectionFactory}"/>

<bean id="jmsQueueConnectionFactory"
          class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
        <property name="targetConnectionFactory" ref="jndiMqConnectionFactory"/>
        <property name="username" value="${mqLogin}"/>
        <property name="password" value="${mqPassword}"/>
    </bean>

<jee:jndi-lookup id="myMqQueue" jndi-name="queue/myMqQueue"/>

<bean id="mqQueueJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsQueueConnectionFactory"/>
    <property name="defaultDestination" ref="myMqQueue"/>
</bean>

<jms:outbound-channel-adapter channel="myMqChannel" jms-template="mqQueueJmsTemplate"/>
...