aldettinger commented on code in PR #165:
URL:
https://github.com/apache/camel-quarkus-examples/pull/165#discussion_r1354863539
##########
message-bridge/src/main/java/org/acme/message/bridge/Producers.java:
##########
@@ -0,0 +1,83 @@
+package org.acme.message.bridge;
+
+import com.ibm.mq.jakarta.jms.MQXAConnectionFactory;
+import com.ibm.msg.client.jakarta.wmq.WMQConstants;
+import io.quarkiverse.messaginghub.pooled.jms.PooledJmsWrapper;
+import io.smallrye.common.annotation.Identifier;
+import jakarta.enterprise.inject.Default;
+import jakarta.jms.ConnectionFactory;
+import jakarta.jms.JMSException;
+import jakarta.transaction.TransactionManager;
+import org.apache.camel.component.jms.JmsComponent;
+import org.eclipse.microprofile.config.ConfigProvider;
+import org.springframework.transaction.jta.JtaTransactionManager;
+
+public class Producers {
+ /**
+ * Create a connection factory for IBM MQ.
+ * <p/>
+ * Since there is no IBM MQ extension for quarkus, we need to create the
connection factory manually
+ *
+ * @param wrapper wrapper that is used to add pooling capabilities to the
connection facory
+ * @return a new connection factory instance
+ */
+ @Identifier("ibmConnectionFactory")
+ public ConnectionFactory createXAConnectionFactory(PooledJmsWrapper
wrapper) {
+ MQXAConnectionFactory mq = new MQXAConnectionFactory();
+ try {
+ mq.setHostName(ConfigProvider.getConfig().getValue("ibm.mq.host",
String.class));
+ mq.setPort(ConfigProvider.getConfig().getValue("ibm.mq.port",
Integer.class));
+
mq.setChannel(ConfigProvider.getConfig().getValue("ibm.mq.channel",
String.class));
+
mq.setQueueManager(ConfigProvider.getConfig().getValue("ibm.mq.queueManagerName",
String.class));
+ mq.setTransportType(WMQConstants.WMQ_CM_CLIENT);
+ mq.setStringProperty(WMQConstants.USERID,
+ ConfigProvider.getConfig().getValue("ibm.mq.user",
String.class));
+ mq.setStringProperty(WMQConstants.PASSWORD,
+ ConfigProvider.getConfig().getValue("ibm.mq.password",
String.class));
+ } catch (JMSException e) {
+ throw new RuntimeException("Unable to create IBM MQ Connection
Factory", e);
+ }
+ return wrapper.wrapConnectionFactory(mq);
+ }
+
+ /**
+ * Define the JtaTransactionManager instance that is used in jms
components.
+ *
+ * @param transactionManager transaction manager
+ * @return JtaTransactionManager instance
+ */
+ @Default
+ JtaTransactionManager manager(TransactionManager transactionManager) {
+ return new JtaTransactionManager(transactionManager);
+ }
+
+ /**
+ * Define the "ibmmq" jms component.
+ *
+ * @param cf ibm mq connection factory that is automatically injected by
Quarkus based on the given identifier
+ * @param tm transaction manager to use
+ * @return a new JmsComponent instance
+ */
+ @Identifier("ibmmq")
+ JmsComponent ibmmq(@Identifier("ibmConnectionFactory") ConnectionFactory
cf, JtaTransactionManager tm) {
Review Comment:
ok, so let's mark the jta transaction manager as singleton in that case.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
