diff options
Diffstat (limited to 'plugins/org.eclipse.osee.ote.core/src/org/eclipse/osee/ote/message/event/OteEventMessageUtil.java')
-rw-r--r-- | plugins/org.eclipse.osee.ote.core/src/org/eclipse/osee/ote/message/event/OteEventMessageUtil.java | 149 |
1 files changed, 0 insertions, 149 deletions
diff --git a/plugins/org.eclipse.osee.ote.core/src/org/eclipse/osee/ote/message/event/OteEventMessageUtil.java b/plugins/org.eclipse.osee.ote.core/src/org/eclipse/osee/ote/message/event/OteEventMessageUtil.java deleted file mode 100644 index f3e92137131..00000000000 --- a/plugins/org.eclipse.osee.ote.core/src/org/eclipse/osee/ote/message/event/OteEventMessageUtil.java +++ /dev/null @@ -1,149 +0,0 @@ -/******************************************************************************* - * Copyright (c) 2013 Boeing. - * All rights reserved. This program and the accompanying materials - * are made available under the terms of the Eclipse Public License v1.0 - * which accompanies this distribution, and is available at - * http://www.eclipse.org/legal/epl-v10.html - * - * Contributors: - * Boeing - initial API and implementation - *******************************************************************************/ -package org.eclipse.osee.ote.message.event; - -import java.util.Dictionary; -import java.util.HashMap; -import java.util.Hashtable; -import java.util.Map; -import java.util.UUID; - -import org.eclipse.osee.ote.core.ServiceUtility; -import org.eclipse.osee.ote.endpoint.OteUdpEndpointSender; -import org.osgi.framework.BundleContext; -import org.osgi.framework.ServiceRegistration; -import org.osgi.service.event.Event; -import org.osgi.service.event.EventAdmin; -import org.osgi.service.event.EventHandler; - -public class OteEventMessageUtil { - - public final static String BYTE_KEY = "oteeventbytes"; - - public final static String BYTE_KEY_2 = "bytes"; - - private static EventAdmin eventAdmin; - - private static EventAdmin getEventAdmin(){ - if(eventAdmin == null){ - eventAdmin = ServiceUtility.getService(EventAdmin.class); - } - return eventAdmin; - } - - public static void sendEvent(OteEventMessage message) { - sendEvent(message, getEventAdmin()); - } - - public static void postEvent(OteEventMessage message) { - postEvent(message, getEventAdmin()); - } - - public static void sendEvent(OteEventMessage message, EventAdmin eventAdmin) { - message.getHeader().UUID_HIGH.setNoLog((long) 0x0); - message.getHeader().UUID_LOW.setNoLog((long) 0x0); - Map<String, Object> data = new HashMap<>(); - data.put(BYTE_KEY, message.getData()); - Event newevent = new Event(message.getHeader().TOPIC.getValue(), data); - eventAdmin.sendEvent(newevent); - } - - public static void postEvent(OteEventMessage message, EventAdmin eventAdmin) { - message.getHeader().UUID_HIGH.setNoLog((long) 0x0); - message.getHeader().UUID_LOW.setNoLog((long) 0x0); - Map<String, Object> data = new HashMap<>(); - data.put(BYTE_KEY, message.getData()); - Event newevent = new Event(message.getHeader().TOPIC.getValue(), data); - eventAdmin.postEvent(newevent); - } - - public static void sendEvent(OteEventMessage message, OteUdpEndpointSender sender) throws InterruptedException { - sender.send(message); - } - - public static void postEvent(OteEventMessage message, OteUdpEndpointSender sender) throws InterruptedException { - sender.send(message); - } - - public static UUID getUUID(OteEventMessage msg) { - return new UUID(msg.getHeader().UUID_HIGH.getValue(), msg.getHeader().UUID_LOW.getValue()); - } - - public static UUID getUUID(byte[] data) { - long low = getLong(data, 74); - long high = getLong(data, 82); - return new UUID(high, low); - } - - private static long getLong(byte[] data, int index){ - return - (long)(0xff & data[index]) << 56 | - (long)(0xff & data[index+1]) << 48 | - (long)(0xff & data[index+2]) << 40 | - (long)(0xff & data[index+3]) << 32 | - (long)(0xff & data[index+4]) << 24 | - (long)(0xff & data[index+5]) << 16 | - (long)(0xff & data[index+6]) << 8 | - (long)(0xff & data[index+7]) << 0; - } - - public static void setUUID(OteEventMessage msg, UUID id) { - msg.getHeader().UUID_HIGH.setValue(id.getMostSignificantBits()); - msg.getHeader().UUID_LOW.setValue(id.getLeastSignificantBits()); - } - - public static OteEventMessage getOteEventMessage(Event event) { - Object obj = event.getProperty(BYTE_KEY); - if (obj != null && obj instanceof byte[]) { - return new OteEventMessage((byte[]) obj); - } else { - obj = event.getProperty(BYTE_KEY_2); - if(obj != null && obj instanceof byte[]){ - return new OteEventMessage((byte[]) obj); - } - } - return null; - } - - public static byte[] getBytes(Event event) { - Object obj = event.getProperty(BYTE_KEY); - if (obj != null && obj instanceof byte[]) { - return (byte[]) obj; - } else { - obj = event.getProperty(BYTE_KEY_2); - if (obj != null && obj instanceof byte[]) { - return (byte[]) obj; - } - return null; - } - } - - public static void putBytes(Event event, OteEventMessage signal) { - signal.getDefaultMessageData().getMem().setData(getBytes(event)); - } - - public static ServiceRegistration<EventHandler> subscribe(String topic, EventHandler handler){ - Dictionary<String, String> props = new Hashtable<>(); - props.put("event.topics", topic); - return ServiceUtility.getContext().registerService(EventHandler.class, handler, props); - } - - public static ServiceRegistration<EventHandler> subscribe(OteEventMessage signal, EventHandler eventHandler) { - BundleContext context = ServiceUtility.getContext(); - if (context == null) { - return null; - } - Hashtable<String, Object> props = new Hashtable<>(); - props.put("event.topics", signal.getHeader().TOPIC.getValue()); - return context.registerService(EventHandler.class, eventHandler, props); - } - -} |