Merge pull request #846 from dakshina99/tm_thread_blocking

[APIM][4.4.0] Handle errors when broker connection is not available
wso2 · Oct 15, 2024 · 701d1ae · 701d1ae
2 parents 1604d95 + 48236f7
commit 701d1ae
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/...ain/java/org/wso2/carbon/event/output/adapter/jms/internal/util/JMSConnectionFactory.java b/...ain/java/org/wso2/carbon/event/output/adapter/jms/internal/util/JMSConnectionFactory.java
@@ -285,9 +285,8 @@ public JMSPooledConnectionHolder getConnectionFromPool() {
         try {
             return (JMSPooledConnectionHolder) this.connectionPool.borrowObject();
         } catch (Exception e) {
-            log.error(e.getMessage(), e);
+            throw new OutputEventAdapterRuntimeException("Error in getting JMS connection from pool", e);
         }
-        return null;
     }
 
 
@@ -366,10 +365,8 @@ public Object makeObject() throws Exception {
                 entry.setProducer(producer);
                 return entry;
             } catch (JMSException e) {
-                log.error(e.getMessage(), e);
-                return null;
+                throw new OutputEventAdapterRuntimeException("Error creating JMS connection holder from JMS CF : " + name, e);
             }
-
         }
 
         @Override