Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAndrew M Finkbeiner2012-08-07 01:49:18 +0000
committerRoberto E. Escobar2012-08-07 01:49:18 +0000
commit41ca46032448b0430c4eea3a68618fb853e2f33e (patch)
treead15f5f5a2a80f3a41bcef7f271ae9c5f7802780 /plugins/org.eclipse.osee.ote.jms
parent22c9f703bb4a85804ab38775b0e017ea0800d33a (diff)
downloadorg.eclipse.osee-41ca46032448b0430c4eea3a68618fb853e2f33e.tar.gz
org.eclipse.osee-41ca46032448b0430c4eea3a68618fb853e2f33e.tar.xz
org.eclipse.osee-41ca46032448b0430c4eea3a68618fb853e2f33e.zip
bug[ats_3NFHL]: Update event sending to handle reuse of messages
Diffstat (limited to 'plugins/org.eclipse.osee.ote.jms')
-rw-r--r--plugins/org.eclipse.osee.ote.jms/META-INF/MANIFEST.MF1
-rw-r--r--plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/bridge/EventToJmsComponent.java6
2 files changed, 6 insertions, 1 deletions
diff --git a/plugins/org.eclipse.osee.ote.jms/META-INF/MANIFEST.MF b/plugins/org.eclipse.osee.ote.jms/META-INF/MANIFEST.MF
index c584637f50..4f7c5212e7 100644
--- a/plugins/org.eclipse.osee.ote.jms/META-INF/MANIFEST.MF
+++ b/plugins/org.eclipse.osee.ote.jms/META-INF/MANIFEST.MF
@@ -12,6 +12,7 @@ Import-Package: org.eclipse.osee.connection.service,
org.eclipse.osee.framework.messaging,
org.eclipse.osee.ote.core.environment,
org.eclipse.osee.ote.message,
+ org.eclipse.osee.ote.message.elements,
org.eclipse.osee.ote.message.event,
org.eclipse.osee.ote.service;resolution:=optional,
org.osgi.service.event;version="1.3.0"
diff --git a/plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/bridge/EventToJmsComponent.java b/plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/bridge/EventToJmsComponent.java
index a6d6b5d436..9f89909894 100644
--- a/plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/bridge/EventToJmsComponent.java
+++ b/plugins/org.eclipse.osee.ote.jms/src/org/eclipse/osee/ote/jms/bridge/EventToJmsComponent.java
@@ -1,5 +1,6 @@
package org.eclipse.osee.ote.jms.bridge;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
@@ -90,7 +91,10 @@ public class EventToJmsComponent extends OseeMessagingListener implements EventH
UUID id = OteEventMessageUtil.getUUID(msg);
if(!id.equals(MYID)){
OteEventMessageUtil.setUUID(msg, MYID);
- OteEventMessageUtil.sendEvent(msg, eventAdmin);
+ Map<String, Object> data = new HashMap<String, Object>();
+ data.put(OteEventMessageUtil.BYTE_KEY, msg.getData());
+ Event newevent = new Event(msg.getHeader().TOPIC.getValue(), data);
+ eventAdmin.sendEvent(newevent);
}
} else {
OseeLog.log(EventToJmsComponent.class, Level.SEVERE, "not a recognized message" + message.getClass());

Back to the top