Pomoc w programowaniu, odpowiedzi na pytania / Wiosna / Spring Integration: MQSeries Message Driven Adapter nie działa - wiosna, integracja sprężyn, kolejka komunikatów, ibm-mq, spring-jms

Spring Integration: MQSeries Message Driven Adapter nie działa - wiosna, integracja sprężyn, kolejka komunikatów, ibm-mq, spring-jms

Potrafię z powodzeniem zintegrować ActiveMQ (w powiązanym kanale opartym na komunikacie) i Kafka (jako kanał wychodzący). Działa dobrze.

Teraz, ponieważ zarówno ActiveMQ, jak i seria MQ są zgodne z JMS, myślę, że przejście będzie łatwiejsze. Ale rzucanie poniżej błędu:

Setup of JMS Message listener invoker failed for destination "queue://abcd" - trying to recover - Cause: JMSQ1112: The operation for a domain specific object was not valid. The operation "createConsumer" is not valid for type "com.ibm.mq.jms.MQQueue"

Moja konfiguracja integracji sprężyn wygląda następująco:

<?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:jms="http://www.springframework.org/schema/integration/jms"
xmlns:integration="http://www.springframework.org/schema/integration"
xmlns:int-kafka="http://www.springframework.org/schema/integration/kafka"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration/jms
http://www.springframework.org/schema/integration/jms/spring-integration-jms.xsd
http://www.springframework.org/schema/integration/kafka
http://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd">

<jms:message-driven-channel-adapter id="requestChannelAdapter" channel="requestChannel"
container="requestListenerContainer" error-channel=""/>


<int-kafka:outbound-channel-adapter
id="kafkaOutboundChannelAdapter" kafka-template="kafkaTemplate"
auto-startup="true" sync="true" channel="inputToKafka" topic="test">
</int-kafka:outbound-channel-adapter>
</beans>

Mój kod wygląda jak poniżej:

public MQQueueConnectionFactory jmsConnectionfactory() {

MQQueueConnectionFactory jmsFactory = new MQQueueConnectionFactory();
jmsFactory.setHostName(hostname);
jmsFactory.setPort(1444);
jmsFactory.setQueueManager(//valid queue manager);
jmsFactory.setChannel(//valid channel name);
jmsFactory.setTransportType(1);
jmsFactory.setSSLCipherSuite(// valid suite);
return jmsFactory;
}

@Bean
public DefaultMessageListenerContainer requestListenerContainer() {

DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setConnectionFactory(jmsConnectionfactory());
container.setSessionTransacted(true);
container.setDestination(helloJMSQueue());
return container;
}


@Bean
public Queue helloJMSQueue() {
return new MQQueue(HELLO_QUEUE);
}

Dlaczego otrzymuję ten błąd? Widziałem kilka postów, które wynikają z wartości pubLocal niedostępnej w jmsTemplate w.r.t MQQueue, ale data ta pochodzi z 2005 roku i zauważyłem, że zmiana została wydana.