Адаптер ресурсов Wildfly Swarm wmqjms.ra
В те моменты я пытаюсь интегрировать адаптер ресурсов wmqjms.ra с Wildfy Swarm, но безуспешно.
Вот шаги, которые я сделал:
1) pom.xml:
<dependency>
<groupId>custom.com.ibm</groupId>
<artifactId>wmq.jmsra</artifactId>
<version>7.5.0.8</version>
<type>rar</type>
</dependency>
<dependency>
<groupId>custom.com.ibm</groupId>
<artifactId>wmq.jmsra</artifactId>
<version>7.5.0.8</version>
<type>jar</type>
<scope>provided</scope>
</dependency>
Примечание. Эти артефакты были вручную развернуты в моем хранилище.m2.
2) project-stage.yml:
swarm:
messaging-activemq:
servers:
default:
jms-queues:
prenotazioneQueue: {}
reinoltroQueue: {}
deployment:
custom.com.ibm:wmq.jmsra.rar:7.5.0.8
resource-adapters:
resource-adapters:
wmq.jmsra-7.5.0.8.rar: #wmq.jmsra.rar:
archive: wmq.jmsra-7.5.0.8.rar
transaction-support: XATransaction
config-properties:
hostName:
value: tqhr0712.sede.corp.sanpaoloimi.com
queueManager:
value: TQHR0712
port:
value: 1412
channel:
value: CH.BSMA.CONN
transportType:
value: CLIENT
connection-definitions:
ManagedConnectionFactoryImpl:
class-name: com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl
jndi-name: java:/ConnectionFactory
use-java-context: true
pool-name: ManagedConnectionFactoryImpl
admin-objects:
QLOCAL.DATAGRAM.WUO.UOS4APPO:
class-name: com.ibm.mq.connector.outbound.MQQueueProxy
jndi-name: java:/jms/queue/reinoltroQueue
pool-name: QAPPO
use-java-context: true
config-properties:
baseQueueName: QLOCAL.DATAGRAM.WUO.UOS4APPO
baseQueueManagerName: TQHR0712
.....
3) Демо Сервис.java
@Stateless
@TransactionManagement(TransactionManagementType.CONTAINER)
public class PrenotazioneServiceImpl {
private static final long serialVersionUID = -8514808232825928216L;
final Logger logger = LoggerFactory.getLogger(PrenotazioneServiceImpl.class);
@Inject
@JMSConnectionFactory("java:/ConnectionFactory")
JMSContext jmsContext;
@Resource(mappedName = "java:/jms/queue/reinoltroQueue")
Queue prenotazioniQueue;
@TransactionAttribute(TransactionAttributeType.REQUIRES_NEW)
public Prenotazione aprirePrenotazione() throws ServiceException { final String METHOD_NAME = getClass().getName() + " -
aprirePrenotazione -";
try {
logger.info(METHOD_NAME + "JMS Context: " +
jmsContext.toString());
logger.info(METHOD_NAME + "JMS Queue: " +
prenotazioniQueue.toString());
logger.info(METHOD_NAME + "Test invio msg di testo");
jmsContext.createProducer().send
(prenotazioniQueue, "Messaggio di prova" );
logger.info(METHOD_NAME + "Msg inviato");
}
catch (PersistenceException nre) {
logger.error("aprirePrenotazione");
throw new ServiceException(nre);
}
return null;
}
....
}
Прежде всего, когда микросервис запущен, в журнале нет ни одной строки, показывающей конфигурацию wmqjmsra.rar, и когда я выполняю вызов REST, журнал показывает, что сообщение отправлено, но я ничего не вижу в очередь, указанная в разделе admin-objects файла project-stage.yml.
Кто-то будет любезен, чтобы помочь мне с этой проблемой, пожалуйста?
Большое спасибо.