1 files changed, 13 insertions, 9 deletions
diff --git a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/ConnectionNode.java b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/ConnectionNode.java
index 4f39b84f78d..0b4a8006195 100644
--- a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/ConnectionNode.java
+++ b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/ConnectionNode.java
@@ -5,6 +5,7 @@
  */
 package org.eclipse.osee.framework.messaging;
 
+import java.util.Properties;
 import org.eclipse.osee.framework.core.exception.OseeCoreException;
 
 /**
@@ -12,20 +13,23 @@ import org.eclipse.osee.framework.core.exception.OseeCoreException;
  */
 public interface ConnectionNode {
 
-   public void subscribe(MessageID messageId, OseeMessagingListener listener, final OseeMessagingStatusCallback statusCallback);
-   public void unsubscribe(MessageID messageId, OseeMessagingListener listener, final OseeMessagingStatusCallback statusCallback);
+   void subscribe(MessageID messageId, OseeMessagingListener listener, final OseeMessagingStatusCallback statusCallback);
+   void subscribe(MessageID messageId, OseeMessagingListener listener, String selector, final OseeMessagingStatusCallback statusCallback);
+   void unsubscribe(MessageID messageId, OseeMessagingListener listener, final OseeMessagingStatusCallback statusCallback);
 
-   public boolean subscribeToReply(MessageID messageId, OseeMessagingListener listener);
-   public boolean unsubscribteToReply(MessageID messageId, OseeMessagingListener listener);
+   boolean subscribeToReply(MessageID messageId, OseeMessagingListener listener);
+   boolean unsubscribteToReply(MessageID messageId, OseeMessagingListener listener);
    
-   public void send(MessageID topic, Object body, final OseeMessagingStatusCallback statusCallback) throws OseeCoreException;
-
-   public void addConnectionListener(ConnectionListener connectionListener);
-   public void removeConnectionListener(ConnectionListener connectionListener);
+   void send(MessageID topic, Object body, final OseeMessagingStatusCallback statusCallback) throws OseeCoreException;
+   void send(MessageID topic, Object body, Properties properties, OseeMessagingStatusCallback statusCallback) throws OseeCoreException;
+   
+   void addConnectionListener(ConnectionListener connectionListener);
+   void removeConnectionListener(ConnectionListener connectionListener);
 
-   public void stop();
+   void stop();
 
    String getSummary();
    String getSubscribers();
    String getSenders();
+
 }