diff options
Diffstat (limited to 'plugins/org.eclipse.osee.framework.messaging.event.res/src/org/eclipse/osee/framework/messaging/event/res/ResEventManager.java')
-rw-r--r-- | plugins/org.eclipse.osee.framework.messaging.event.res/src/org/eclipse/osee/framework/messaging/event/res/ResEventManager.java | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/plugins/org.eclipse.osee.framework.messaging.event.res/src/org/eclipse/osee/framework/messaging/event/res/ResEventManager.java b/plugins/org.eclipse.osee.framework.messaging.event.res/src/org/eclipse/osee/framework/messaging/event/res/ResEventManager.java index bdb0c401b50..1fc951be24f 100644 --- a/plugins/org.eclipse.osee.framework.messaging.event.res/src/org/eclipse/osee/framework/messaging/event/res/ResEventManager.java +++ b/plugins/org.eclipse.osee.framework.messaging.event.res/src/org/eclipse/osee/framework/messaging/event/res/ResEventManager.java @@ -12,6 +12,7 @@ import org.eclipse.osee.framework.messaging.ConnectionNode; import org.eclipse.osee.framework.messaging.OseeMessagingListener;
import org.eclipse.osee.framework.messaging.OseeMessagingStatusCallback;
import org.eclipse.osee.framework.messaging.ReplyConnection;
+import org.eclipse.osee.framework.messaging.event.res.msgs.RemoteBranchEvent1;
import org.eclipse.osee.framework.messaging.event.res.msgs.RemoteTransactionEvent1;
/**
@@ -64,11 +65,14 @@ public class ResEventManager implements OseeMessagingStatusCallback { public void addingRemoteEventService(ConnectionNode connectionNode) {
this.connectionNode = connectionNode;
connectionNode.subscribe(ResMessages.RemoteTransactionEvent1, new RemoteTransactionEvent1Listener(), instance);
+ connectionNode.subscribe(ResMessages.RemoteBranchEvent1, new RemoteBranchEvent1Listener(), instance);
}
public void kick(RemoteEvent remoteEvent) throws Exception {
if (remoteEvent instanceof RemoteTransactionEvent1) {
sendRemoteEvent(ResMessages.RemoteTransactionEvent1, remoteEvent);
+ } else if (remoteEvent instanceof RemoteBranchEvent1) {
+ sendRemoteEvent(ResMessages.RemoteBranchEvent1, remoteEvent);
} else {
System.out.println("ResEventManager: Unhandled remote event " + remoteEvent);
}
@@ -121,4 +125,23 @@ public class ResEventManager implements OseeMessagingStatusCallback { }
}
+ public class RemoteBranchEvent1Listener extends OseeMessagingListener {
+
+ public RemoteBranchEvent1Listener() {
+ super(RemoteBranchEvent1.class);
+ }
+
+ @Override
+ public void process(final Object message, Map<String, Object> headers, ReplyConnection replyConnection) {
+ RemoteBranchEvent1 remoteBranchEvent1 = (RemoteBranchEvent1) message;
+ System.err.println(String.format(getClass().getSimpleName() + " - received [%s]",
+ message.getClass().getSimpleName()));
+ try {
+ frameworkEventListener.onEvent(remoteBranchEvent1);
+ } catch (RemoteException ex) {
+ System.err.println(getClass().getSimpleName() + " - process: " + ex.getLocalizedMessage());
+ }
+ }
+ }
+
}
|