Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorafinkbein2010-03-22 15:18:06 -0400
committerafinkbein2010-03-22 15:18:06 -0400
commit5c6ba0daf49a7931239010c2858a3f27502afc18 (patch)
treeca116b5b36bec14eebb089c5262e3ee8580f584f /plugins/org.eclipse.osee.framework.messaging
parentffc60031226bb3cec253622b2432acac05e47073 (diff)
downloadorg.eclipse.osee-5c6ba0daf49a7931239010c2858a3f27502afc18.tar.gz
org.eclipse.osee-5c6ba0daf49a7931239010c2858a3f27502afc18.tar.xz
org.eclipse.osee-5c6ba0daf49a7931239010c2858a3f27502afc18.zip
"Team Workflow" - 40MK0 - "Create a new Ote Server Launch and OteService"
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/activemq/ActiveMqMessageListenerWrapper.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ActiveMqMessageListenerWrapper.java b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ActiveMqMessageListenerWrapper.java
index 7860f3b42c..e338eef362 100644
--- a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ActiveMqMessageListenerWrapper.java
+++ b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/activemq/ActiveMqMessageListenerWrapper.java
@@ -72,7 +72,9 @@ class ActiveMqMessageListenerWrapper implements MessageListener {
private void process(javax.jms.Message message, ReplyConnection replyConnection) throws JMSException, OseeCoreException{
Map<String, Object> headers = new HashMap<String, Object>();
for(OseeMessagingListener listener:listeners){
- listener.process(activeMqUtil.translateMessage(message, listener.getClazz()), headers, replyConnection);
+ if(listener != null){
+ listener.process(activeMqUtil.translateMessage(message, listener.getClazz()), headers, replyConnection);
+ }
}
OseeLog.log(Activator.class, Level.FINE, String.format("recieved message %s - %s", message.getJMSDestination().toString(), message.toString()));
}

Back to the top