Name the pool for debugging purposes

quarkiverse · Sep 1, 2023 · 4f8edfe · 4f8edfe
1 parent cffbed1
commit 4f8edfe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/runtime/src/main/java/io/quarkiverse/ironjacamar/runtime/ConnectionManagerFactory.java b/runtime/src/main/java/io/quarkiverse/ironjacamar/runtime/ConnectionManagerFactory.java
@@ -28,14 +28,15 @@ public ConnectionManagerFactory(TransactionIntegration transactionIntegration, C
         this.ccm = ccm;
     }
 
-    public TxConnectionManager createConnectionManager(ManagedConnectionFactory mcf) {
+    public TxConnectionManager createConnectionManager(String id, ManagedConnectionFactory mcf) {
         Pool pool = new PoolFactory()
                 .create(PoolStrategy.POOL_BY_CRI,
                         mcf,
                         new PoolConfiguration(),
                         false,
                         false,
                         ManagedConnectionPoolFactory.DEFAULT_IMPLEMENTATION);
+        pool.setName("pool-" + id);
         return new org.jboss.jca.core.connectionmanager.ConnectionManagerFactory()
                 .createTransactional(
                         TransactionSupport.TransactionSupportLevel.XATransaction,

diff --git a/runtime/src/main/java/io/quarkiverse/ironjacamar/runtime/IronJacamarSupport.java b/runtime/src/main/java/io/quarkiverse/ironjacamar/runtime/IronJacamarSupport.java
@@ -43,7 +43,7 @@ public IronJacamarContainer createContainer(String id, String kind) {
         } catch (ResourceException re) {
             throw new DeploymentException("Cannot deploy resource adapter", re);
         }
-        TxConnectionManager connectionManager = connectionManagerFactory.createConnectionManager(managedConnectionFactory);
+        TxConnectionManager connectionManager = connectionManagerFactory.createConnectionManager(id, managedConnectionFactory);
         return new IronJacamarContainer(resourceAdapterFactory, resourceAdapter, managedConnectionFactory,
                 connectionManager);
     }