Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorafinkbein2010-08-06 17:54:20 -0400
committerafinkbein2010-08-06 17:54:20 -0400
commit14f96559fda0729eefc13153630de3c058b03ea9 (patch)
tree56132ca7f1d53bb5493fdb535e5ce018dfa34ce6 /plugins/org.eclipse.osee.framework.messaging
parent92e5b5e2ec8cb42b56e48f5e3e918852e5dad29f (diff)
downloadorg.eclipse.osee-14f96559fda0729eefc13153630de3c058b03ea9.tar.gz
org.eclipse.osee-14f96559fda0729eefc13153630de3c058b03ea9.tar.xz
org.eclipse.osee-14f96559fda0729eefc13153630de3c058b03ea9.zip
Diffstat (limited to 'plugins/org.eclipse.osee.framework.messaging')
-rw-r--r--plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/FailoverConnectionNode.java5
-rw-r--r--plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ConnectionNodeActiveMq.java7
2 files changed, 8 insertions, 4 deletions
diff --git a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/FailoverConnectionNode.java b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/FailoverConnectionNode.java
index c6131dd54d..e160ab36b9 100644
--- a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/FailoverConnectionNode.java
+++ b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/FailoverConnectionNode.java
@@ -17,7 +17,9 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
+
import javax.jms.JMSException;
+
import org.eclipse.osee.framework.core.exception.OseeCoreException;
import org.eclipse.osee.framework.logging.OseeLog;
import org.eclipse.osee.framework.messaging.ConnectionListener;
@@ -248,7 +250,7 @@ public class FailoverConnectionNode implements ConnectionNode, Runnable {
if (connectionNode.isConnected()) {
connected();
}
- } catch (OseeCoreException ex) {
+ }catch (OseeCoreException ex) {
OseeLog.log(FailoverConnectionNode.class, Level.FINE, ex);
notConnected();
}
@@ -299,6 +301,5 @@ public class FailoverConnectionNode implements ConnectionNode, Runnable {
public void onException(JMSException ex) {
connectionNode.stop();
- run();
}
}
diff --git a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ConnectionNodeActiveMq.java b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ConnectionNodeActiveMq.java
index 46479d810b..768603d26c 100644
--- a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ConnectionNodeActiveMq.java
+++ b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ConnectionNodeActiveMq.java
@@ -19,6 +19,7 @@ import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.logging.Level;
+
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.ExceptionListener;
@@ -30,6 +31,7 @@ import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TemporaryTopic;
import javax.jms.Topic;
+
import org.apache.activemq.ActiveMQConnectionFactory;
import org.eclipse.osee.framework.core.exception.OseeCoreException;
import org.eclipse.osee.framework.core.exception.OseeWrappedException;
@@ -323,15 +325,16 @@ class ConnectionNodeActiveMq implements ConnectionNodeFailoverSupport, MessageLi
session = null;
}
} catch (JMSException ex) {
- OseeLog.log(ConnectionNodeActiveMq.class, Level.SEVERE, ex);
+ OseeLog.log(ConnectionNodeActiveMq.class, Level.FINEST, ex);
}
try {
if (connection != null) {
+ connection.setExceptionListener(null);
connection.close();
connection = null;
}
} catch (JMSException ex) {
- OseeLog.log(ConnectionNodeActiveMq.class, Level.SEVERE, ex);
+ OseeLog.log(ConnectionNodeActiveMq.class, Level.FINEST, ex);
}
}

Back to the top