Tentei chamar um Enterprise MQ no Spring Boot 2.5 usando javax.jms
dependências do MQ. A conexão está sendo feita com sucesso. Abaixo está o meu pom.xml
e o código. Estou usando credenciais de ID de aplicativo para conectar-me à fila que defini na classe UserCredentialsProvider.
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<dependency>
<groupId>com.ibm.mq</groupId>
<artifactId>com.ibm.mq.allclient</artifactId>
<version>0.0.0.3</version>
</dependency>
<dependency>
<groupId>javax.jms</groupId>
<artifactId>javax.jms-api</artifactId>
<version>2.0.1</version>
</dependency>
Código -
@Bean
public MQQueueConnectionFactory mqQueueConnectionFactory() {
MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
mqQueueConnectionFactory.setHostName(host);
try {
mqQueueConnectionFactory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
mqQueueConnectionFactory.setCCSID(1208);
mqQueueConnectionFactory.setChannel(channel);
mqQueueConnectionFactory.setPort(port);
mqQueueConnectionFactory.setQueueManager(queueManager);
} catch (Exception e) {
e.printStackTrace();
}
return mqQueueConnectionFactory;
}
@Bean
UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter(MQQueueConnectionFactory mqQueueConnectionFactory) {
UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter = new UserCredentialsConnectionFactoryAdapter();
userCredentialsConnectionFactoryAdapter.setUsername(username);
userCredentialsConnectionFactoryAdapter.setPassword(password);
userCredentialsConnectionFactoryAdapter.setTargetConnectionFactory(mqQueueConnectionFactory);
return userCredentialsConnectionFactoryAdapter;
}
@Bean
@Primary
public CachingConnectionFactory cachingConnectionFactory(UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter) {
CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
cachingConnectionFactory.setTargetConnectionFactory(userCredentialsConnectionFactoryAdapter);
cachingConnectionFactory.setSessionCacheSize(500);
cachingConnectionFactory.setReconnectOnException(true);
return cachingConnectionFactory;
}
@Bean
public PlatformTransactionManager jmsTransactionManager(CachingConnectionFactory cachingConnectionFactory) {
JmsTransactionManager jmsTransactionManager = new JmsTransactionManager();
jmsTransactionManager.setConnectionFactory(cachingConnectionFactory);
return jmsTransactionManager;
}
@Bean
public JmsOperations jmsOperations(CachingConnectionFactory cachingConnectionFactory) throws JMSException {
JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory);
jmsTemplate.setReceiveTimeout(receiveTimeout);
Connection c = jmsTemplate.getConnectionFactory().createConnection();
System.out.println(c.getMetaData()); //the connection is established successfully
return jmsTemplate;
}
Agora, o que fiz foi tentar migrar para o Spring Boot 3.1.1. Eu tive que mudar minhas dependências do MQ no POM para usar jakarta
no lugar do javax
pacote. Abaixo está o meu POM atualizado:
<dependency>
<groupId>jakarta.jms</groupId>
<artifactId>jakarta.jms-api</artifactId>
</dependency>
<dependency>
<groupId>com.ibm.mq</groupId>
<artifactId>com.ibm.mq.jakarta.client</artifactId>
<version>9.3.0.0</version>
</dependency>
Atualizei o código acima para usar o jakarta Connection Factory em vez de JMS , mas agora estou recebendo o erro MQRC_NOT_AUTHORIZED(2035).
Quais modificações devo executar para que isso funcione no Spring Boot 3.1 com com.ibm.mq.jakarta.client.jar 9.3?
No 9.3, o padrão para autenticação MQ em classes Java e JMS mudou do modo de compatibilidade para MQCSP. É por isso que agora você está recebendo um 2035. Para fazer a conexão funcionar novamente, você precisa voltar ao modo de compatibilidade.
Existem alguns métodos para voltar ao modo de compatibilidade, dois deles são:
JmsConstants.USER_AUTHENTICATION_MQCSP
comofalse
com.ibm.mq.cfg.jmqi.useMQCSPauthentication
comoN
.Por exemplo:
System.setProperty("com.ibm.mq.cfg.jmqi.useMQCSPauthentication", "N")
-Dcom.ibm.mq.cfg.jmqi.useMQCSPauthentication=N
Para obter mais detalhes, consulte Autenticação de conexão com o cliente Java .
9.3 quebrá-lo provavelmente significa uma das três coisas:
CONNAUTH
configurado comADOPTCTX(NO)
.Você pode testar se é o nº 3 ativando o modo de compatibilidade e enviando intencionalmente uma senha incorreta. Se funcionar, você sabe que é o número 3.
Você pode testar se é o número 2 desativando o modo de compatibilidade, enviando a senha correta e especificando
-Duser.name=username
, se funcionar, provavelmente é o número 2`Se ambos os itens acima falharem, é provável que seja o número 1.