diff options
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.java | 4 |
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 7860f3b42cc..e338eef362d 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())); } |