Chapter 31. Resource Adapters A Jakarta Connectors Resource Adapter lets your applications communicate with any messaging provider. It configures how Jakarta EE components such as MDBs and other Jakarta Enterprise Beans, and even Servlets, can send or receive messages. 31.1. About the Integrated Artemis Resource Adapter JBoss EAP 7 includes an integrated Artemis resource adapter, which uses the pooled-connection-factory element to configure the outbound and inbound connections of the resource adapter. Outbound Connection Outbound connections are defined using the pooled-connection-factory element, which is then used in Jakarta EE deployments by Jakarta Enterprise Beans and servlets to send messages to and receive messages from queues or topics. Because connections created from connection factories are created in the scope of the application server, they can use application server features like the following: Connection pooling Authentication using the security domains defined by the application server Participation in XA transactions using the transaction manager This is a major difference with a pooled-connection-factory as these features are not available with a basic connection-factory like InVmConnectionFactory or RemoteConnectionFactory . Also, be aware that with a connection factory defined using pooled-connection-factory , it is not possible to do a lookup using JNDI from an external standalone Jakarta Messaging client. Inbound Connections Inbound connections are used only by message-driven beans (MDBs) to receive message from a queue or a topic. MDBs are stateless session beans that listen on a queue or topic. They must implement the public onMessage(Message message) method, which is called when a message is sent to a queue or a topic. The Artemis resource adapter is responsible for receiving the message from the queue or the topic and passing it to the onMessage(Message message) method. For this purpose it configures the inbound connection, which defines the location of the integrated Artemis server and some additional elements. Each MDB session bean uses a thread from the client thread pool to consume the message from the destination. If the maximum pool size is not defined, it is determined to be eight (8) times the number of CPU core processors. For systems with many MDB sessions, such as test suites, this can potentially lead to thread exhaustion and force MDBs to wait for a free thread from the pool. You can increase the maximum pool size of client thread pool using the management CLI. The following command sets the maximum client thread pool size to 128 . For information about how to configure the client thread pool size, see Client Thread Management . For more information about MDBs, see Message Driven Beans in Developing Jakarta Enterprise Beans Applications for JBoss EAP. 31.2. Using the Integrated Artemis Resource Adapter for Remote Connections JBoss EAP includes a resource adapter to make connections to its integrated ActiveMQ Artemis messaging server. By default the pooled-connection-factory defined in the messaging-activemq subsystem uses the adapter to make the connections. However, you can use the same resource adapter to make connections to an Artemis server running inside a remote instance of JBoss EAP as well. Important The activemq-ra pooled connection factory, which is configured by default in the messaging-activemq subsystem, has the java:jboss/DefaultJMSConnectionFactory entry assigned. This entry is required by the messaging-activemq subsystem. If you decide to remove the activemq-ra pooled connection factory, you must assign this entry to a different connection factory. Otherwise you will see the following error in the server log on deployment. To connect to an Artemis server running inside a remote instance of JBoss EAP, create a new pooled-connection-factory by following the steps below. Create an outbound-socket-binding pointing to the remote messaging server: Create a remote-connector referencing the outbound-socket-binding created in step 1. Create a pooled-connection-factory referencing the remote-connector created in step 2. Note Artemis 1.x required a prefix on destination names (jms.topic for topics and jms.queue for queues). Artemis 2.x does not require prefixes, but for compatibility with Artemis 1.x, EAP still adds the prefix and directs Artemis to run in compatibility mode. If you connect to a remote Artemis 2.x server, it may not be in compatibility mode and you may not need the prefixes. When using destinations without a prefix, you can configure the connection factory not to include the prefixes by setting the attribute enable-amq1-prefix to false . Configuring an MDB to use a pooled-connection-factory After the pooled-connection-factory is configured to connect to a remote Artemis server, Message-Driven Beans (MDB) wanting to read messages from the remote server must be annotated with the @ResourceAdapter annotation using the name of the pooled-connection-factory resource. import org.jboss.ejb3.annotation.ResourceAdapter; @ResourceAdapter("remote-artemis") @MessageDriven(name = "MyMDB", activationConfig = { ... }) public class MyMDB implements MessageListener { public void onMessage(Message message) { ... } } If the MDB needs to send messages to the remote server, it must inject the pooled-connection-factory by looking it up using one of its JNDI entries . @Inject @JMSConnectionFactory("java:/jms/remoteCF") private JMSContext context; Configuring the Jakarta Messaging destination An MDB must also specify the destination from which it will consume messages. The standard way to do this is to define a destinationLookup activation config property that corresponds to a JNDI lookup on the local server. @ResourceAdapter("remote-artemis") @MessageDriven(name = "MyMDB", activationConfig = { @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "myQueue"), ... }) public class MyMDB implements MessageListener { ... } If the local server does not include a JNDI binding for the remote Artemis server, specify the name of the destination, as configured in the remote Artemis server, using the destination activation config property and set the useJNDI activation config property to false . This instructs the Artemis resource adapter to automatically create the Jakarta Messaging destination without requiring a JNDI lookup. @ResourceAdapter("remote-artemis") @MessageDriven(name = "MyMDB", activationConfig = { @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "false"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "myQueue"), ... }) public class MyMDB implements MessageListener { ... } In the above example, the activation config properties configure the MDB to consume messages from the Jakarta Messaging Queue named myQueue hosted on the remote Artemis server. In most cases, the MDB does not need to lookup other destinations to process the consumed messages, and it can use the JMSReplyTo destination if it is defined on the message. If the MDB needs any other Jakarta Messaging destinations defined on the remote server, it must use client-side JNDI. See Connecting to a Server for more information. 31.3. Configuring the Artemis Resource Adapter to Connect to Red Hat AMQ You can configure the integrated Artemis resource adapter to connect to a remote installation of Red Hat AMQ 7, which then becomes the Jakarta Messaging provider for your JBoss EAP 7.4 applications. This allows JBoss EAP to be a client for the remote Red Hat AMQ 7 server. If you require support for other messaging protocols, such as AMQP or STOMP, you must configure Red Hat AMQ 7 as your messaging broker. The Artemis resource adapter integrated in the JBoss EAP server can then be used to process messages for the deployed applications. Limitations of the Integrated Resource Adapter Dynamic Creation of Queues and Topics Be aware that the Artemis resource adapter that is integrated in JBoss EAP 7.4 does not support dynamic creation of queues and topics in the Red Hat AMQ 7 broker. You must configure all queue and topic destinations directly on the remote Red Hat AMQ 7 server. Creation of Connection Factories Although Red Hat AMQ allows connection factories to be configured using both the pooled-connection-factory and the external-context , there is a difference in the way each connection factory is created. When the external-context is used to create the connection factory, it creates simple Jakarta Messaging connection factory as defined in the Jakarta Messaging specification . The newly created connection factory is equivalent to the RemoteConnectionFactory , which is defined by default in messaging-activemq subsystem. This connection factory is independent of the other components in the application server, meaning it is not aware of, nor is it able to use, other components like the transaction manager or the security manager. For this reason, only the pooled-connection-factory can be used to create connection factories in JBoss EAP 7. The external-context can only be used to register Jakarta Messaging destinations, which are already configured on the remote AMQ 7 broker, into the JNDI tree of the JBoss EAP 7 server so that local deployments can look them up or inject them. Connection factories created by configuring the external-context or the connection-factory elements cannot be used to connect to the remote AMQ 7 broker as they do not use the Artemis resource adapter. Only connection factories created by configuring the pooled-connection-factory element are supported for use when connecting to the remote AMQ7 broker. Configure JBoss EAP to Use a Remote Red Hat AMQ Server You can use the management CLI to configure JBoss EAP to use a remote installation of Red Hat AMQ 7 as the messaging provider by following the steps below: Configure the queue in the Red Hat AMQ 7 broker.xml deployment descriptor file. <configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd"> <core xmlns="urn:activemq:core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq:core "> ... <acceptors> <acceptor name="netty-acceptor">tcp://localhost:61616?anycastPrefix=jms.queue.;multicastPrefix=jms.topic. </acceptor> </acceptors> <addresses> <address name="MyQueue"> <anycast> <queue name="MyQueue" /> </anycast> </address> <address name="MyOtherQueue"> <anycast> <queue name="MyOtherQueue" /> </anycast> </address> <address name="MyTopic"> <multicast/> </address> <addresses> ... </core> </configuration> Note The Artemis resource adapter that is included with JBoss EAP uses the ActiveMQ Artemis Jakarta Messaging Client 2.x. This client requires anycastPrefix and multicastPrefix prefixing on the address. It also expects the queue name to be the same as the address name. Create the remote connector. This creates the following remote-connector in the messaging-activemq subsystem. <subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0"> ... <remote-connector name="netty-remote-throughput" socket-binding="messaging-remote-throughput"/> ... </subsystem> Add the remote destination outbound socket binding. This creates the following remote-destination in the outbound-socket-binding element configuration. <outbound-socket-binding name="messaging-remote-throughput"> <remote-destination host="localhost" port="61616"/> </outbound-socket-binding> Add a pooled connection factory for the remote connector. This creates the following pooled-connection-factory in the messaging-activemq subsystem. <subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0"> ... <pooled-connection-factory name="activemq-ra-remote" entries="java:/RemoteJmsXA java:jboss/RemoteJmsXA" connectors="netty-remote-throughput"/> ... </subsystem> Note Artemis 1.x required a prefix on destination names (jms.topic for topics and jms.queue for queues). Artemis 2.x does not require prefixes, but for compatibility with Artemis 1.x, EAP still adds the prefix and directs Artemis to run in compatibility mode. If you connect to a remote Artemis 2.x server, it may not be in compatibility mode and you may not need the prefixes. When using destinations without a prefix, you can configure the connection factory not to include the prefixes by setting the attribute enable-amq1-prefix to false . Create the external-context bindings for the queues and topics. This creates the following external-context bindings in the naming subsystem. <subsystem xmlns="urn:jboss:domain:naming:2.0"> ... <bindings> <external-context name="java:global/remoteContext" module="org.apache.activemq.artemis" class="javax.naming.InitialContext"> <environment> <property name="java.naming.factory.initial" value="org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory"/> <property name="java.naming.provider.url" value="tcp://127.0.0.1:61616"/> <property name="queue.MyQueue" value="MyQueue"/> <property name="queue.MyOtherQueue" value="MyOtherQueue"/> <property name="topic.MyTopic" value="MyTopic"/> </environment> </external-context> </bindings> ... </subsystem> Create the lookup entry for the Jakarta Messaging queues and topics by setting the JNDI name to the Red Hat AMQ 7 address name value. This creates a mapping between the JNDI name and the Red Hat AMQ 7 address name. This creates the following lookup configurations in the naming subsystem. <subsystem xmlns="urn:jboss:domain:naming:2.0"> ... <lookup name="java:/MyQueue" lookup="java:global/remoteContext/MyQueue"/> <lookup name="java:/MyOtherQueue" lookup="java:global/remoteContext/MyOtherQueue"/> <lookup name="java:/MyTopic" lookup="java:global/remoteContext/MyTopic"/> ... </subsystem> Alternatively, define the /subsystem=messaging-activemq/external-jms-queue or the /subsystem=messaging-activemq/external-jms-topic resource instead of configuring naming subsystem. For example: This creates the following resource: <subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0"> ... <external-jms-queue name="MyQueue" entries="java:/MyQueue"/> ... </subsystem> Note The external-jms-queue resource does not provide operations for queue management and statistics. JBoss EAP is now configured to use the remote installation of Red Hat AMQ 7 as the messaging provider. 31.4. Jakarta Messaging Resources Configuration for a Remote Artemis-based Broker From the management CLI, you can configure Jakarta Messaging resources for a remote Artemis-based broker, such as Red Hat AMQ 7, using the @JMSConnectionFactoryDefinition annotation or the @JMSDestinationDefinition annotation. You can also configure the resources from the management console. The remote ActiveMQ server resources do not require a local instance of Artemis. This helps reduce the memory and CPU footprint of the JBoss EAP image. 31.4.1. Jakarta Messaging Resources Configuration Using the JMSConnectionFactoryDefinition Annotation JBoss EAP uses the @JMSConnectionFactoryDefinition annotation to define a connection factory. This connection factory can connect to a local or a remote Artemis broker. The resourceAdapter element of the @JMSConnectionFactoryDefinition annotation then refers to the name of the pooled-connection-factory defined in the messaging-subsystem which can connect to a remote Artemis broker. The resourceAdapter element defines which resource adapter is used for creating a connection factory or in which resource adapter a connection factory is defined. When the resourceAdapter element is not defined in the @JMSConnectionFactoryDefinition annotation, the messaging-activemq subsystem uses the JNDI name of the connection factory by default. This is known as default binding. The default binding is defined using the jms-connection-factory attribute at /subsystem=ee/service=default-bindings . If the resourceAdapter element is specified or one can be defined from the default binding for the jms-connection-factory and if it is a pooled-connection-factory to a remote broker, you can use it to connect to the remote broker. If the resourceAdapter is not defined in the messaging-activemq subsystem or one cannot be obtained from the default binding for the jms-connection-factory , the task of creating the Jakarta Messaging resources is delegated to the resource-adapters subsystem based on the resource adapter's admin-objects and connection-definitions resources. The following sections provide examples of how to configure and use the @JMSConnectionFactoryDefinition annotation. Configuring @JMSConnectionFactoryDefinition Using the Default Resource Adapter Create a socket binding to remote instance: Create a connector: Create a pooled connection factory: Define the default Jakarta Messaging connection factory for the ee subsystem: Use the @JMSConnectionFactoryDefinition annotation in your application code: @JMSConnectionFactoryDefinition(name="java:/jms/remote-amq/JmsConnectionFactory") Configuring @JMSConnectionFactoryDefinition Using a Remote Artemis Broker Create a connector: Create a pooled connection factory: Define the default Jakarta Messaging connection factory for the ee subsystem: Use the @JMSConnectionFactoryDefinition annotation in your application code: @JMSConnectionFactoryDefinition( name="java:app/myCF" resourceAdapter="myPCF" ) Configuring @JMSConnectionFactoryDefinition Using a Third-party JMS Resource Adapter Create a connector: Create a pooled connection factory: Define the default Jakarta Messaging connection factory for the ee subsystem: Use the @JMSConnectionFactoryDefinition annotation in your application code: @JMSConnectionFactoryDefinition( name="java:app/myCF" resourceAdapter="wsmq" ) 31.4.2. Jakarta Messaging Resources Configuration Using the JMSDestinationDefinition Annotation You can use the server resources to create the required destinations for a pooled-connection-factory to a local broker. If the resourceAdapter element points to a pooled-connection-factory name and it is defined in a local broker, for example, /subsystem/messaging-activemq/server=default , then it creates destinations in the local Artemis broker. Note If you need to create destinations in a remote Artemis-based broker, then the pooled-connection-factory must be defined in the messaging-activemq subsystem. If the resourceAdapter set in the @JMSDestinationDefinition annotation matches the resourceAdapter element defined for the server in the messaging-activemq subsystem, then the destination is created in this broker, irrespective of whether the connector in the pooled-connection-factory points to a local or a remote Artemis broker. Configuring Jakarta Messaging Resources Using the JMSDestinationDefinition Annotation Create a connector: Create a pooled connection factory: Define the default Jakarta Messaging connection factory for the ee subsystem: Use the @JMSDestinationDefinition annotation in your application code: @JMSDestinationDefinition( name = "java:/jms/queue/MessageBeanQueue", interfaceName = "javax.jms.Queue", destinationName = "MessageBeanQueue" properties= { "management-address=remote-activemq.management" } ) 31.4.3. Configuring Remote ActiveMQ Server Resources Using the Management Console You can configure the following remote ActiveMQ server resources from the management console: Generic Connector In VM Connector HTTP Connector Remote Connector Discovery Group Connection Factory Pooled Connection Factory External JMS Queue External JMS Topic To configure the remote ActiveMQ server resources from the management console: Access the management console and navigate to Configuration Subsystems Messaging (ActiveMQ) Remote ActiveMQ Server and click View . In the navigation pane, click the resource you want to configure. 31.5. Deploying a Red Hat JBoss A-MQ Resource Adapter You can deploy the resource adapter provided by the Red Hat JBoss A-MQ product and have, for example, Red Hat JBoss A-MQ 6.3.0, become the external Jakarta Messaging provider for JBoss EAP. See Install the ActiveMQ Resource Adapter in Integrating with JBoss Enterprise Application Platform , which is in the Red Hat JBoss A-MQ documentation suite, for details on how to deploy and configure a Red Hat JBoss A-MQ resource adapter. Note Be aware that the product name changed from Red Hat JBoss A-MQ in the 6.x releases to Red Hat AMQ in the 7.x releases. 31.5.1. Issues with the Red Hat JBoss A-MQ 6 Resource Adapter JBoss EAP will track and monitor applications, looking for unclosed resources. While useful in many cases, such monitoring might cause unexpected behavior when an application tries to re-use a closed instance of UserTransaction in a single method. Add the attribute tracking="false" to the <connection-definition/> element when configuring the Red Hat JBoss A-MQ resource adapter if your applications re-use connections in this way. <connection-definition class-name="..." tracking="false" ... /> The Red Hat JBoss A-MQ 6 resource adapter does not implement XAResourceWrapper from the Narayana API, which is used by JBoss EAP. Consequently, when the Transaction Manager sends a commit to all the XA transaction participants and then crashes while waiting for a reply, it will go on indefinitely logging warnings until records of the committed transaction are removed from its object store. The Red Hat JBoss A-MQ 6 resource adapter returns the code XAER_RMERR when an error, such as a network disconnection, occurs during the call of the commit method protocol. This behavior breaks the XA specification since the correct return code should be XAER_RMFAIL or XAER_RETRY . Consequently, the transaction is left in an unknown state on the message broker side, which can cause data inconsistency in some cases. A message will be logged similar to the one below when the unexpected error code is returned. Red Hat JBoss A-MQ 6.x supports the JMS 1.1 specification that is included with Java EE 6. It does not support the Jakarta Messaging 2.0 specification that was introduced in Jakarta EE 8 and is supported in JBoss EAP 7. If you need to send messages to a remote Red Hat JBoss A-MQ broker, you must use the JMS 1.1 API within your application code. For more information about Red Hat JBoss A-MQ 6.x supported standards, see Red Hat JBoss A-MQ Supported Standards and Protocols . 31.6. Deploying the IBM MQ Resource Adapter About IBM MQ IBM MQ is the Messaging Oriented Middleware (MOM) product offering from IBM that allows applications on distributed systems to communicate with each other. This is accomplished through the use of messages and message queues. IBM MQ is responsible for delivering messages to the message queues and for transferring data to other queue managers using message channels. For more information about IBM MQ, see IBM MQ on the IBM products website. Summary IBM MQ can be configured as an external Jakarta Messaging provider for JBoss EAP 7.4. This section covers the steps to deploy and configure the IBM MQ resource adapter in JBoss EAP. This deployment and configuration can be accomplished by using the management CLI tool or the web-based management console. See JBoss EAP supported configurations for the most current information about the supported configurations of IBM MQ. Note You must restart your system after configuring your IBM MQ resource adapter for the configuration changes to take effect. Prerequisites Before you get started, you must verify the version of the IBM MQ resource adapter and understand its configuration properties. The IBM MQ resource adapter is supplied as a Resource Archive (RAR) file called wmq.jmsra.rar . You can obtain the wmq.jmsra.rar file from /opt/mqm/java/lib/jca/wmq.jmsra.rar . See JBoss EAP supported configurations for information about the specific versions that are supported for each release of JBoss EAP. You must know the following IBM MQ configuration values. Refer to the IBM MQ product documentation for details about these values. MQ_QUEUE_MANAGER : The name of the IBM MQ queue manager MQ_HOST_NAME : The host name used to connect to the IBM MQ queue manager MQ_CHANNEL_NAME : The server channel used to connect to the IBM MQ queue manager MQ_QUEUE_NAME : The name of the destination queue MQ_TOPIC_NAME : The name of the destination topic MQ_PORT : The port used to connect to the IBM MQ queue manager MQ_CLIENT : The transport type For outbound connections, you must also be familiar with the following configuration value: MQ_CONNECTIONFACTORY_NAME : The name of the connection factory instance that will provide the connection to the remote system Procedure Note The following are default configurations provided by IBM and are subject to change. Please refer to IBM MQ documentation for more information. First, deploy the resource adapter manually by copying the wmq.jmsra.rar file to the EAP_HOME /standalone/deployments/ directory. , use the management CLI to add the resource adapter and configure it. Note that the transaction-support element was set to XATransaction . When using transactions, be sure to supply the security domain of the XA recovery datasource, as in the example below. For more information about XA Recovery see Configuring XA Recovery in the JBoss EAP Configuration Guide . For non-transactional deployments, change the value of transaction-support to NoTransaction . Now that the resource adapter is created, you can add the necessary configuration elements to it. Add an admin-object for queues and configure its properties. Add an admin-object for topics and configure its properties. Add a connection definition for a managed connection factory and configure its properties. If you want to change the default provider for the EJB3 messaging system in JBoss EAP from JBoss EAP 7 messaging to IBM MQ, use the management CLI to modify the ejb3 subsystem as follows: Configure the @ActivationConfigProperty and @ResourceAdapter annotations in the MDB code as follows: @MessageDriven(name="IbmMqMdb", activationConfig = { @ActivationConfigProperty(propertyName = "destinationType",propertyValue = "javax.jms.Queue"), @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "false"), @ActivationConfigProperty(propertyName = "hostName", propertyValue = " MQ_HOST_NAME "), @ActivationConfigProperty(propertyName = "port", propertyValue = " MQ_PORT "), @ActivationConfigProperty(propertyName = "channel", propertyValue = " MQ_CHANNEL_NAME "), @ActivationConfigProperty(propertyName = "queueManager", propertyValue = " MQ_QUEUE_MANAGER "), @ActivationConfigProperty(propertyName = "destination", propertyValue = " MQ_QUEUE_NAME "), @ActivationConfigProperty(propertyName = "transportType", propertyValue = " MQ_CLIENT ") }) @ResourceAdapter(value = "wmq.jmsra- VERSION .rar") @TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED) public class IbmMqMdb implements MessageListener { } Be sure to replace the VERSION in the @ResourceAdapter value with the actual version in the name of the RAR. Activate your resource adapter: 31.6.1. Limitations and Known Issues with the IBM MQ Resource Adapters The following table lists known issues with the IBM MQ resource adapters. A checkmark ( ✔ ) in the version column indicates the issue is a problem for that version of the resource adapter. Table 31.1. Known Issues with the IBM MQ Resource Adapters JIRA Description of Issue IBM MQ 8 IBM MQ 9 JBEAP-503 The IBM MQ resource adapter returns different String values for the Queue.toString() and QueueBrowser.getQueue().toString() methods. Queue is instance of the com.ibm.mq.connector.outbound.MQQueueProxy class, which is different from the com.ibm.mq.jms.MQQueue class that is returned by the QueueBrowser.htmlQueueBrowser.getQueue() method. These classes contain different implementations of the toString() method. Be aware that you cannot rely on these toString() methods to return the same value. ✔ ✔ JBEAP-511 , JBEAP-550 , JBEAP-3686 The following restrictions apply to message property names for IBM MQ. In the activation-config section of the deployment descriptor, you must not configure the destinationName property using special characters such as _ , & , or | . Use of these characters causes the MDB deployment to fail with a com.ibm.msg.client.jms.DetailedInvalidDestinationException exception. In the activation-config section of the deployment descriptor, you must not configure the destinationName property using the java:/ prefix. Use of this prefix causes the MDB deployment to fail with a com.ibm.msg.client.jms.DetailedInvalidDestinationException exception. A property must not begin with "JMS" or "usr.JMS" as they are reserved for use by IBM MQ Jakarta Messaging classes. Exceptions are noted on the IBM Knowledge Center website. See Property name restrictions for IBM MQ, Version 8.0 and Property name restrictions for IBM MQ, Version 9.0 on the IBM Knowledge Center website for the complete list of message property name restrictions for each version of the resource adapter. ✔ ✔ JBEAP-549 When specifying the destination property name value for an MDB using the @ActivationConfigProperty annotation, you must use all upper case letters. For example: @ActivationConfigProperty(propertyName = "destination", propertyValue = "QUEUE") ✔ ✔ JBEAP-624 If the IBM MQ resource adapter is used to create a connection factory in a Jakarta EE deployment using the @JMSConnectionFactoryDefinition annotation, you must specify the resourceAdapter property. Otherwise, the deployment will fail. @JMSConnectionFactoryDefinition( name = "java:/jms/WMQConnectionFactory", interfaceName = "javax.jms.ConnectionFactory", resourceAdapter = "wmq.jmsra", properties = { "channel=<channel>", "hostName=<hostname_wmq_broker>", "transportType=<transport_type>", "queueManager=<queue_manager>" } ) ✔ ✔ JBEAP-2339 The IBM MQ resource adapter is able to read messages from queues and topics even before the connection has started. This means a consumer can consume messages before the connection is started. To avoid hitting this issue, use connection factories created by the remote IBM MQ broker using the external-context and not connection factories created by IBM MQ resource adapter. ✔ ✔ JBEAP-3685 Once <transaction-support>XATransaction</transaction-support> is set, a JMSContext is always JMSContext.SESSION_TRANSACTED , whether it was created using injection or manually. In the following code example, the @JMSSessionMode(JMSContext.DUPS_OK_ACKNOWLEDGE) is ignored and the JMSContext remains at JMSContext.SESSION_TRANSACTED . @Inject @JMSConnectionFactory("jms/CF") @JMSPasswordCredential(userName="myusername", password="mypassword") @JMSSessionMode(JMSContext.DUPS_OK_ACKNOWLEDGE) transient JMSContext context3; ✔ ✔ JBEAP-14633 According to the Jakarta Messaging specification, the QueueSession interface cannot be used to create objects specific to the publish/subscribe domain and certain methods that inherit from Session should throw an javax.jms.IllegalStateException . One such method is such QueueSession.createTemporaryTopic() . Instead of throwing an javax.jms.IllegalStateException , the IBM MQ resource adapter throws a java.lang.NullPointerException . ✔ ✔ JBEAP-14634 The MQTopicProxy.getTopicName() returns different topic name than was set by the IBM MQ broker. For example, if the topic name was set to topic://MYTOPIC?XMSC_WMQ_BROKER_PUBQ_QMGR=QM , the MQTopicProxy returns topic://MYTOPIC . ✔ ✔ JBEAP-14636 The default autoStart setting for the JMSContext is false , meaning the underlying connection used by the JMSContext is not started automatically when a consumer is created. This setting should default to true . ✔ ✔ JBEAP-14640 The IBM MQ resource adapter throws DetailedJMSException instead of a JMSSecurityException when invalid credentials are used and logs the following error to the server console. The following is an example of code that can cause this issue. QueueConnection qc = queueConnectionFactory.createQueueConnection("invalidUserName", "invalidPassword"); ✔ ✔ JBEAP-14642 Due to an invalid class cast conversion by the resource adapter in the MQMessageProducer.send(Destination destination, Message message) and MQMessageProducer.send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, CompletionListener completionListener) methods, the IBM MQ resource adapter throws a JMSException and logs the following error message to the server console. This is because the JNDI name used in the queue or topic lookup is com.ibm.mq.connector.outbound.MQQueueProxy/MQTopicProxy . ✔ ✔ JBEAP-14643 The setDeliveryDelay(expDeliveryDelay) method on the JMSProducer interface does not change the setting. After calling this method, it remains at the default setting of 0 . ✔ ✔ JBEAP-14670 If work is done on a QueueSession that was created prior to a UserTransaction.begin() , that work is not considered part of the transaction. This means that any message sent to the queue using this session is not committed by a UserTransaction.commit() , and after a UserTransaction.rollback() , the message remains on the queue. ✔ ✔ JBEAP-14675 If you close a connection and then immediately create a JMSContext with the same clientID , the IBM MQ resource adapter intermittently logs the following error to the server console. This issue does not occur when there is a delay in creating the new JMSContext after the connection with the same clientID is closed. ✔ ✔ JBEAP-15535 If a stateful session bean tries to send a message to a topic while in a container managed transaction (CMT), the message send fails with the following message. The stack trace shows it to be caused by the following exception. ✔ ✔ JBEAP-20758 When you deploy either the IBM MQ 8 or IBM MQ 9 resource adapter, wmq.jmsra.rar , on JBoss EAP, the following error message displays on the server console: The IBM MQ v9.0.0.4 resource adapter was tested as part of the Jakarta Messaging providers tests for JBoss EAP 7.4. You can choose to ignore this warning message or you can disable the archive validation by setting the enabled attribute to false . For example: ✔ ✔ 31.7. Deploying a Generic Jakarta Messaging Resource Adapter JBoss EAP can be configured to work with third-party Jakarta Messaging providers; however, not all Jakarta Messaging providers produce a Jakarta Messaging Jakarta Connectors resource adapter for integration with Jakarta application platforms. This procedure covers the steps required to configure the generic Jakarta Messaging resource adapter included in JBoss EAP to connect to a Jakarta Messaging provider. In this procedure, Tibco EMS 8 is used as an example Jakarta Messaging provider. Other Jakarta Messaging providers may require different configuration. Important Before using the generic Jakarta Messaging resource adapter, check with the Jakarta Messaging provider to see if they have their own resource adapter that can be used with JBoss EAP. The generic Jakarta Messaging Jakarta Connectors resource adapter should only be used when a Jakarta Messaging provider does not provide its own resource adapter. Before you can configure a generic resource adapter, you will need to do the following: Your Jakarta Messaging provider server must already be configured and ready for use. Any binaries required for the provider's Jakarta Messaging implementation will be needed. You will need to know the values of the following Jakarta Messaging provider properties to be able to look up its Jakarta Messaging resources, such as connection factories, queues or topics. java.naming.factory.initial java.naming.provider.url java.naming.factory.url.pkgs In the example XML used in this procedure, these parameters are written as PROVIDER_FACTORY_INITIAL , PROVIDER_URL , and PROVIDER_CONNECTION_FACTORY respectively. Replace these placeholders with the Jakarta Messaging provider values for your environment. 31.7.1. Configure a Generic Jakarta Messaging Resource Adapter for Use with a Third-party Jakarta Messaging Provider Create and configure the resource adapter module. Create a JBoss EAP module that contains all the libraries required to connect and communicate with the Jakarta Messaging provider. This module will be named org.jboss.genericjms.provider . Create the following directory structure: EAP_HOME /modules/org/jboss/genericjms/provider/main Copy the binaries required for the provider's Jakarta Messaging implementation to EAP_HOME /modules/org/jboss/genericjms/provider/main . Note For Tibco EMS, the binaries required are tibjms.jar and tibcrypt.jar from the Tibco installation's lib directory. Create a module.xml file in EAP_HOME /modules/org/jboss/genericjms/provider/main as below, listing the JAR files from the steps as resources: <module xmlns="urn:jboss:module:1.5" name="org.jboss.genericjms.provider"> <resources> <!-- all jars required by the Jakarta Messaging provider, in this case Tibco --> <resource-root path="tibjms.jar"/> <resource-root path="tibcrypt.jar"/> </resources> <dependencies> <module name="javax.api"/> <module name="javax.jms.api"/> </dependencies> </module> Add the module to the ee subsystem using the following CLI command: Create and configure a Java Naming and Directory Interface external context to the Jakarta Messaging provider. The Jakarta Messaging resources, such as connection factories and destinations, are looked up in the Jakarta Messaging provider. Add an external context in the JBoss EAP instance so that any local lookup for this resource will automatically look up the resource on the remote Jakarta Messaging provider. Note In this procedure, EAP_HOME /standalone/configuration/standalone-full.xml is used as the JBoss EAP configuration file. Use the management CLI to create an external Java Naming and Directory Interface context and include its configuration properties. The properties in the example below should be replaced by the correct value to connect to the remote Jakarta Messaging provider. For example, some Jakarta Messaging providers, such as Tibco EMS, do not support the Java Naming and Directory Interface lookup(Name) method. In these cases, add the org.jboss.as.naming.lookup.by.string property with a value of true to work around this issue. Check the adapter's documentation for information on required properties and their values. With the external context configured properly, any Java Naming and Directory Interface lookup to a resource starting with java:global/remoteJMS/ will be done on the remote Jakarta Messaging provider. As an example, if a message-driven bean performs a Java Naming and Directory Interface lookup for java:global/remoteJMS/Queue1 , the external context will connect to the remote Jakarta Messaging provider and perform a lookup for the Queue1 resource. Alternatively, you can make a Java Naming and Directory Interface lookup to the remote server without using an external-context when looking up the Java Naming and Directory Interface name. To do so, use the CLI to create a new binding that references the external-context , as in the example below. In the example above, an application that does a Java Naming and Directory Interface lookup for java:/jms/queue/myQueue will locate the queue named myQueue on the remote server. Create the generic Jakarta Messaging resource adapter. Use the management CLI to create the resource adapter Configure the generic Jakarta Messaging resource adapter. Use the management CLI to configure the resource adapter's connection-definition and other elements. Configure the default message-driven bean pool in the ejb3 subsystem to use the generic resource adapter. The generic Jakarta Messaging resource adapter is now configured and ready for use. Below is an example of using the resource adapter when creating a new message-driven bean. Example: Code Using the Generic Resource Adapter @MessageDriven(name = "HelloWorldQueueMDB", activationConfig = { // The generic Jakarta Messaging resource adapter requires the Java Naming and Directory Interface bindings // for the actual remote connection factory and destination @ActivationConfigProperty(propertyName = "connectionFactory", propertyValue = "java:global/remoteJMS/XAQCF"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:global/remoteJMS/Queue1"), @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") }) public class HelloWorldQueueMDB implements MessageListener { public void onMessage(Message message) { // called every time a message is received from the _Queue1_ queue on the Jakarta Messaging provider. } } Important When using the generic Jakarta Messaging resource adapter, ensure you set the session to be transacted, to avoid a potential NullPointerException error. The error occurs because the generic Jakarta Messaging resource adapter attempts processing of parameters, when the Jakarta EE specification states that they are not to be processed. This is accomplished by doing the following: connection.createSession(true, Session.SESSION_TRANSACTED); You can also use the pooled connection factory from the resource adapter: @Resource(lookup = "java:/jms/XAQCF") private ConnectionFactory cf; It is not possible to inject a resource from an external context directly but it is possible to inject an external context and then perform a lookup. For example, a lookup for a queue deployed in a Tibco EMS broker would be as follows. @Resource(lookup = "java:global/remoteJMS") private Context context; ... Queue queue = (Queue) context.lookup("Queue1") 31.8. Using the Resource Annotation Using the @Resource annotation, Jakarta Enterprise Beans can directly inject Jakarta Messaging resources or connection factories. You can specify the following parameters using the @Resource annotations: lookup name mappedName To inject a resource, you must specify the Java Naming and Directory Interface (JNDI) name of the resource in one of these parameters. 31.8.1. Injecting Jakarta Messaging Resources Define your queue as shown below: <jms-queue name="OutQueue" entries="jms/queue/OutQueue java:jboss/exported/jms/queue/OutQueue"/> Inject this queue by specifying its Java Naming and Directory Interface name in the lookup , name , or mappedName parameter of the @Resource annotation. For example: @Resource(lookup = "java:jboss/exported/jms/queue/OutQueue") public Queue myOutQueue; 31.8.2. Injecting Connection Factories Define your connection factory as shown below. The example shows a JmsXA pooled connection factory. <pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="xa"/> Inject the default activemq-ra pooled connection factory as shown below: @Resource(lookup = "java:/JmsXA") private ConnectionFactory cf; 31.8.3. The Limitations and Known Issues for the Generic Jakarta Messaging Resource Adapter The Jakarta Messaging API does not provide a programmatic way to create the Jakarta Messaging resources, only the features that are defined in the Jakarta Messaging 2.0 specification are supported. For more information about the specification, see Jakarta Messaging 2.0 specification . EE.5.18.4 Jakarta Messaging Connection Factory Resource Definition This is the ability for an application to define a Jakarta Messaging ConnectionFactory resource. EE.5.18.5 Jakarta Messaging Destination Definition This is the ability for an application to define a Jakarta Messaging Destination resource.

Commands:
/subsystem=messaging-activemq:write-attribute(name=global-client-thread-pool-max-size,value=128)
WFLYCTL0412: Required services that are not installed:" => ["jboss.naming.context.java.jboss.DefaultJMSConnectionFactory"]
/socket-binding-group=standard-sockets/remote-destination-outbound-socket-binding=remote-server:add(host=<server host>, port=8080)
/subsystem=messaging-activemq/server=default/http-connector=remote-http-connector:add(socket-binding=remote-server,endpoint=http-acceptor)
/subsystem=messaging-activemq/server=default/pooled-connection-factory=remote-artemis:add(connectors=[remote-http-connector], entries=[java:/jms/remoteCF])
import org.jboss.ejb3.annotation.ResourceAdapter; @ResourceAdapter("remote-artemis") @MessageDriven(name = "MyMDB", activationConfig = { ... }) public class MyMDB implements MessageListener { public void onMessage(Message message) { } }
@Inject @JMSConnectionFactory("java:/jms/remoteCF") private JMSContext context;
@ResourceAdapter("remote-artemis") @MessageDriven(name = "MyMDB", activationConfig = { @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "myQueue"), }) public class MyMDB implements MessageListener { }
@ResourceAdapter("remote-artemis") @MessageDriven(name = "MyMDB", activationConfig = { @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "false"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "myQueue"), }) public class MyMDB implements MessageListener { }
<configuration xmlns="urn:activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd"> <core xmlns="urn:activemq:core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq:core "> <acceptors> <acceptor name="netty-acceptor">tcp://localhost:61616?anycastPrefix=jms.queue.;multicastPrefix=jms.topic. </acceptor> </acceptors> <addresses> <address name="MyQueue"> <anycast> <queue name="MyQueue" /> </anycast> </address> <address name="MyOtherQueue"> <anycast> <queue name="MyOtherQueue" /> </anycast> </address> <address name="MyTopic"> <multicast/> </address> <addresses> </core> </configuration>
/subsystem=messaging-activemq/remote-connector=netty-remote-throughput:add(socket-binding=messaging-remote-throughput)
<subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0"> <remote-connector name="netty-remote-throughput" socket-binding="messaging-remote-throughput"/> </subsystem>
/socket-binding-group=standard-sockets/remote-destination-outbound-socket-binding=messaging-remote-throughput:add(host=localhost, port=61616)
<outbound-socket-binding name="messaging-remote-throughput"> <remote-destination host="localhost" port="61616"/> </outbound-socket-binding>
/subsystem=messaging-activemq/pooled-connection-factory=activemq-ra-remote:add(transaction=xa,entries=[java:/RemoteJmsXA, java:jboss/RemoteJmsXA],connectors=[netty-remote-throughput])
<subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0"> <pooled-connection-factory name="activemq-ra-remote" entries="java:/RemoteJmsXA java:jboss/RemoteJmsXA" connectors="netty-remote-throughput"/> </subsystem>
/subsystem=naming/binding=java\:global\/remoteContext:add(binding-type=external-context, class=javax.naming.InitialContext, module=org.apache.activemq.artemis, environment=[java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory, java.naming.provider.url=tcp://127.0.0.1:61616, queue.MyQueue=MyQueue, queue.MyOtherQueue=MyOtherQueue, topic.MyTopic=MyTopic])
<subsystem xmlns="urn:jboss:domain:naming:2.0"> <bindings> <external-context name="java:global/remoteContext" module="org.apache.activemq.artemis" class="javax.naming.InitialContext"> <environment> <property name="java.naming.factory.initial" value="org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory"/> <property name="java.naming.provider.url" value="tcp://127.0.0.1:61616"/> <property name="queue.MyQueue" value="MyQueue"/> <property name="queue.MyOtherQueue" value="MyOtherQueue"/> <property name="topic.MyTopic" value="MyTopic"/> </environment> </external-context> </bindings> </subsystem>
/subsystem=naming/binding=java\:\/MyQueue:add(lookup=java:global/remoteContext/MyQueue,binding-type=lookup) /subsystem=naming/binding=java\:\/MyOtherQueue:add(lookup=java:global/remoteContext/MyOtherQueue,binding-type=lookup) /subsystem=naming/binding=java\:\/MyTopic:add(lookup=java:global/remoteContext/MyTopic,binding-type=lookup)
<subsystem xmlns="urn:jboss:domain:naming:2.0"> <lookup name="java:/MyQueue" lookup="java:global/remoteContext/MyQueue"/> <lookup name="java:/MyOtherQueue" lookup="java:global/remoteContext/MyOtherQueue"/> <lookup name="java:/MyTopic" lookup="java:global/remoteContext/MyTopic"/> </subsystem>
/subsystem=messaging-activemq/external-jms-queue=MyQueue:add(entries=[java:/MyQueue])
<subsystem xmlns="urn:jboss:domain:messaging-activemq:4.0"> <external-jms-queue name="MyQueue" entries="java:/MyQueue"/> </subsystem>
/socket-binding-group=standard-sockets/remote-destination-outbound-socket-binding=messaging-remote-throughput:add(host=127.0.0.2, port=5445)
/subsystem=messaging-activemq/remote-connector=remote-amq:add(socket-binding="messaging-remote-throughput")
/subsystem=messaging-activemq/pooled-connection-factory=activemq-ra-remote:add(entries=["java:/jms/remote-amq/JmsConnectionFactory"],connectors=["remote-amq"]
/subsystem=ee/service=default-bindings:write-attribute(name=jms-connection-factory, value="java:/jms/remote-amq/JmsConnectionFactory")
@JMSConnectionFactoryDefinition(name="java:/jms/remote-amq/JmsConnectionFactory")
/subsystem=messaging-activemq/remote-connector=remote-amq:add(socket-binding="messaging-remote-throughput")
/subsystem=messaging-activemq/pooled-connection-factory=activemq-ra-remote:add(entries=["java:/jms/remote-amq/JmsConnectionFactory"],connectors=["remote-amq"])
/subsystem=ee/service=default-bindings:write-attribute(name=jms-connection-factory, value="java:/jms/remote-amq/JmsConnectionFactory")
@JMSConnectionFactoryDefinition( name="java:app/myCF" resourceAdapter="myPCF" )
/subsystem=messaging-activemq/remote-connector=remote-amq:add(socket-binding="messaging-remote-throughput")
/subsystem=messaging-activemq/pooled-connection-factory=activemq-ra-remote:add(entries=["java:/jms/remote-amq/JmsConnectionFactory"],connectors=["remote-amq"])
/subsystem=ee/service=default-bindings:write-attribute(name=jms-connection-factory, value="java:/jms/remote-amq/JmsConnectionFactory")
@JMSConnectionFactoryDefinition( name="java:app/myCF" resourceAdapter="wsmq" )
/subsystem=messaging-activemq/remote-connector=remote-amq:add(socket-binding="messaging-remote-throughput")
/subsystem=messaging-activemq/pooled-connection-factory=activemq-ra-remote:add(entries=["java:/jms/remote-amq/JmsConnectionFactory"],connectors=["remote-amq"])
/subsystem=ee/service=default-bindings:write-attribute(name=jms-connection-factory, value="java:/jms/remote-amq/JmsConnectionFactory")
@JMSDestinationDefinition( name = "java:/jms/queue/MessageBeanQueue", interfaceName = "javax.jms.Queue", destinationName = "MessageBeanQueue" properties= { "management-address=remote-activemq.management" } )
<connection-definition class-name="..." tracking="false" ... />
WARN [com.arjuna.ats.jtax] ...: XAResourceRecord.rollback caused an XA error: ARJUNA016099: Unknown error code:0 from resource ... in transaction ...: javax.transaction.xa.XAException: Transaction ... has not been started.
/subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar:add(archive=wmq.jmsra.rar, transaction-support=XATransaction)
/subsystem=resource-adapters/resource-adapter=test/connection-definitions=test:write-attribute(name=recovery-security-domain,value=myDomain)
/subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar:add(archive=wmq.jmsra.rar, transaction-support=NoTransaction)
/subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/admin-objects=queue-ao:add(class-name=com.ibm.mq.connector.outbound.MQQueueProxy, jndi-name=java:jboss/ MQ_QUEUE_NAME ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/admin-objects=queue-ao/config-properties=baseQueueName:add(value= MQ_QUEUE_NAME ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/admin-objects=queue-ao/config-properties=baseQueueManagerName:add(value= MQ_QUEUE_MANAGER )
/subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/admin-objects=topic-ao:add(class-name=com.ibm.mq.connector.outbound.MQTopicProxy, jndi-name=java:jboss/ MQ_TOPIC_NAME ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/admin-objects=topic-ao/config-properties=baseTopicName:add(value= MQ_TOPIC_NAME ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/admin-objects=topic-ao/config-properties=brokerPubQueueManager:add(value= MQ_QUEUE_MANAGER )
/subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/connection-definitions=mq-cd:add(class-name=com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl, jndi-name=java:jboss/ MQ_CONNECTIONFACTORY_NAME , tracking=false) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/connection-definitions=mq-cd/config-properties=hostName:add(value= MQ_HOST_NAME ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/connection-definitions=mq-cd/config-properties=port:add(value= MQ_PORT ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/connection-definitions=mq-cd/config-properties=channel:add(value= MQ_CHANNEL_NAME ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/connection-definitions=mq-cd/config-properties=transportType:add(value= MQ_CLIENT ) /subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar/connection-definitions=mq-cd/config-properties=queueManager:add(value= MQ_QUEUE_MANAGER )
/subsystem=ejb3:write-attribute(name=default-resource-adapter-name,value=wmq.jmsra.rar)
@MessageDriven(name="IbmMqMdb", activationConfig = { @ActivationConfigProperty(propertyName = "destinationType",propertyValue = "javax.jms.Queue"), @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "false"), @ActivationConfigProperty(propertyName = "hostName", propertyValue = " MQ_HOST_NAME "), @ActivationConfigProperty(propertyName = "port", propertyValue = " MQ_PORT "), @ActivationConfigProperty(propertyName = "channel", propertyValue = " MQ_CHANNEL_NAME "), @ActivationConfigProperty(propertyName = "queueManager", propertyValue = " MQ_QUEUE_MANAGER "), @ActivationConfigProperty(propertyName = "destination", propertyValue = " MQ_QUEUE_NAME "), @ActivationConfigProperty(propertyName = "transportType", propertyValue = " MQ_CLIENT ") }) @ResourceAdapter(value = "wmq.jmsra- VERSION .rar") @TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED) public class IbmMqMdb implements MessageListener { }
/subsystem=resource-adapters/resource-adapter=wmq.jmsra.rar:activate()
@ActivationConfigProperty(propertyName = "destination", propertyValue = "QUEUE")
@JMSConnectionFactoryDefinition( name = "java:/jms/WMQConnectionFactory", interfaceName = "javax.jms.ConnectionFactory", resourceAdapter = "wmq.jmsra", properties = { "channel=<channel>", "hostName=<hostname_wmq_broker>", "transportType=<transport_type>", "queueManager=<queue_manager>" } )
@Inject @JMSConnectionFactory("jms/CF") @JMSPasswordCredential(userName="myusername", password="mypassword") @JMSSessionMode(JMSContext.DUPS_OK_ACKNOWLEDGE) transient JMSContext context3;
WARN [org.jboss.jca.core.connectionmanager.pool.strategy.PoolByCri] (EJB default - 7) IJ000604: Throwable while attempting to get a new connection: null: com.ibm.mq.connector.DetailedResourceException: MQJCA1011: Failed to allocate a {JMS} connection., error code: MQJCA1011 An internal error caused an attempt to allocate a connection to fail. See the linked exception for details of the failure.
QueueConnection qc = queueConnectionFactory.createQueueConnection("invalidUserName", "invalidPassword");
SVR-ERROR: Expected JMSException, received com.ibm.mq.connector.outbound.MQQueueProxy cannot be cast to com.ibm.mq.jms.MQDestination
ERROR [io.undertow.request] (default task-1) UT005023: Exception handling request to /jmsServlet-1.0-SNAPSHOT/: com.ibm.msg.client.jms.DetailedJMSRuntimeException: MQJCA0002: An exception occurred in the IBM MQ layer. See the linked exception for details. A call to IBM MQ classes for Java(tm) caused an exception to be thrown.
SVR-ERROR: com.ibm.msg.client.jms.DetailedJMSException: JMSWMQ2007: Failed to send a message to destination ' MDB_NAME TOPIC_NAME '
com.ibm.mq.MQException: JMSCMQ0001: IBM MQ call failed with compcode '2' ('MQCC_FAILED') reason '2072' ('MQRC_SYNCPOINT_NOT_AVAILABLE')
WARN [org.jboss.as.connector.deployers.RADeployer] (MSC service thread 1-8) IJ020017: Invalid archive: file:/<path-to-jboss>/jboss-eap-7.4/standalone/tmp/vfs/temp/tempa02bdd5ee254e590/content-135e13d4f38704fc/contents/
/subsystem=jca/archive-validation=archive-validation:write-attribute(name=enabled, value=false)
<module xmlns="urn:jboss:module:1.5" name="org.jboss.genericjms.provider"> <resources> <!-- all jars required by the Jakarta Messaging provider, in this case Tibco --> <resource-root path="tibjms.jar"/> <resource-root path="tibcrypt.jar"/> </resources> <dependencies> <module name="javax.api"/> <module name="javax.jms.api"/> </dependencies> </module>
/subsystem=ee:list-add(name=global-modules, value={"name" => "org.jboss.genericjms.provider", "slot" =>"main"}
/subsystem=naming/binding="java:global/remoteJMS":add(binding-type=external-context,module=org.jboss.genericjms.provider,class=javax.naming.InitialContext,environment=[java.naming.factory.initial=com.tibco.tibjms.naming.TibjmsInitialContextFactory,java.naming.provider.url=tcp://<hostname>:7222,org.jboss.as.naming.lookup.by.string=true])
/subsystem=naming/binding=java\:\/jms\/queue\/myQueue:add(binding-type=lookup, lookup=java:global/remoteJMS/jms/queue/myQueue)
/subsystem=resource-adapters/resource-adapter=generic-ra:add(module=org.jboss.genericjms,transaction-support=XATransaction)
/subsystem=resource-adapters/resource-adapter=generic-ra/connection-definitions=tibco-cd:add(class-name=org.jboss.resource.adapter.jms.JmsManagedConnectionFactory, jndi-name=java:/jms/XAQCF) /subsystem=resource-adapters/resource-adapter=generic-ra/connection-definitions=tibco-cd/config-properties=ConnectionFactory:add(value=XAQCF) /subsystem=resource-adapters/resource-adapter=generic-ra/connection-definitions=tibco-cd/config-properties=JndiParameters:add(value="java.naming.factory.initial=com.tibco.tibjms.naming.TibjmsInitialContextFactory;java.naming.provider.url=tcp://<hostname>:7222") /subsystem=resource-adapters/resource-adapter=generic-ra/connection-definitions=tibco-cd:write-attribute(name=security-application,value=true)
/subsystem=ejb3:write-attribute(name=default-resource-adapter-name, value=generic-ra)
@MessageDriven(name = "HelloWorldQueueMDB", activationConfig = { // The generic Jakarta Messaging resource adapter requires the Java Naming and Directory Interface bindings // for the actual remote connection factory and destination @ActivationConfigProperty(propertyName = "connectionFactory", propertyValue = "java:global/remoteJMS/XAQCF"), @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:global/remoteJMS/Queue1"), @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"), @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") }) public class HelloWorldQueueMDB implements MessageListener { public void onMessage(Message message) { // called every time a message is received from the _Queue1_ queue on the Jakarta Messaging provider. } }
@Resource(lookup = "java:/jms/XAQCF") private ConnectionFactory cf;
@Resource(lookup = "java:global/remoteJMS") private Context context; Queue queue = (Queue) context.lookup("Queue1")
<jms-queue name="OutQueue" entries="jms/queue/OutQueue java:jboss/exported/jms/queue/OutQueue"/>
@Resource(lookup = "java:jboss/exported/jms/queue/OutQueue") public Queue myOutQueue;
<pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm" transaction="xa"/>
@Resource(lookup = "java:/JmsXA") private ConnectionFactory cf;