[JBPM-10187] Adding traces for session info loading

apache · Aug 17, 2023 · 613fac1 · 613fac1
1 parent be46da7
commit 613fac1
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 4 deletions.
diff --git a/...rools-persistence-api/src/main/java/org/drools/persistence/jta/JtaTransactionManager.java b/...rools-persistence-api/src/main/java/org/drools/persistence/jta/JtaTransactionManager.java
@@ -117,9 +117,9 @@ protected javax.transaction.TransactionManager findTransactionManager(UserTransa
                               jndiName );
                 return tm;
             } catch ( NamingException ex ) {
-                logger.debug( "No JTA TransactionManager found at fallback JNDI location [{}]",
+                logger.debug( "No JTA TransactionManager found at fallback JNDI location [{}]. Exception message {}",
                               jndiName,
-                              ex);
+                              ex.getMessage());
             }
         }
 

diff --git a/...rools-persistence-jpa/src/main/java/org/drools/persistence/jpa/JpaPersistenceContext.java b/...rools-persistence-jpa/src/main/java/org/drools/persistence/jpa/JpaPersistenceContext.java
@@ -32,7 +32,7 @@
 
 public class JpaPersistenceContext implements PersistenceContext {
 
-    private static Logger logger = LoggerFactory.getLogger(JpaPersistenceContext.class);
+    protected static Logger logger = LoggerFactory.getLogger(JpaPersistenceContext.class);
 
     private EntityManager em;
     protected final boolean isJTA;
@@ -68,7 +68,7 @@ public PersistentSession persist(PersistentSession entity) {
     }
 
     public PersistentSession findSession(Long id) {
-
+        logger.trace("Reading session info {}, id");
         SessionInfo sessionInfo = null;
         if( this.pessimisticLocking ) {
             sessionInfo = this.em.find( SessionInfo.class, id, lockMode );

diff --git a/...a/src/main/java/org/drools/persistence/jpa/marshaller/JPAPlaceholderResolverStrategy.java b/...a/src/main/java/org/drools/persistence/jpa/marshaller/JPAPlaceholderResolverStrategy.java
@@ -203,13 +203,19 @@ private boolean isEntity(Object o){
     public void onStart(TransactionManager txm) {
         if (persister.get() == null) {
             EntityManager em = emf.createEntityManager();
+            log.trace ("Created EM {} for name {}",em, name);
             persister.set(new EntityPersister(em));
         }
     }
 
     @Override
     public void onEnd(TransactionManager txm) {
         EntityPersister em = persister.get();
+        if (em == null) {
+            log.warn ("EM is null for {} and status {}", name, txm.getStatus());
+            return;
+        }
+        log.trace ("Executing onEnd for {} with status {}", name, txm.getStatus());
         if(txm.getStatus() == TransactionManager.STATUS_ROLLEDBACK) {
             // this is pretty much of a hack but for avoiding issues when rolling back we need to set to null 
             // the primary key of the entities (simple types)
@@ -239,6 +245,7 @@ public void onEnd(TransactionManager txm) {
             });
         }
         if (em != null) {
+            log.trace ("Closing EM {} for name {}",em, name);
             em.close();
             persister.set(null);
         }