Адаптер ресурсов 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.

Кто-то будет любезен, чтобы помочь мне с этой проблемой, пожалуйста?

Большое спасибо.

0 ответов

Другие вопросы по тегам