1 files changed, 52 insertions, 0 deletions
diff --git a/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/AbstractMessageListener.java b/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/AbstractMessageListener.java
new file mode 100644
index 000000000..bfbc1c187
--- /dev/null
+++ b/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/AbstractMessageListener.java
@@ -0,0 +1,52 @@
+/*******************************************************************************
+ * Copyright (c) 2004, 2007 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.client.msg.core;
+
+import org.eclipse.osee.ote.message.MessageSystemException;
+import org.eclipse.osee.ote.message.listener.IOSEEMessageListener;
+
+/**
+ * @author Ken J. Aguilar
+ */
+public abstract class AbstractMessageListener implements ISubscriptionListener, IOSEEMessageListener {
+
+   private final IMessageSubscription subscription;
+
+   protected AbstractMessageListener(IMessageSubscription subscription) {
+      this.subscription = subscription;
+   }
+
+   @Override
+   public void subscriptionCanceled(IMessageSubscription subscription) {
+      if (subscription.isResolved()) {
+         subscription.getMessage().removeListener(this);
+      }
+   }
+
+   @Override
+   public void subscriptionResolved(IMessageSubscription subscription) {
+      if (subscription.isResolved()) {
+         subscription.getMessage().addListener(this);
+      }
+   }
+
+   @Override
+   public void subscriptionUnresolved(IMessageSubscription subscription) {
+   }
+
+   @Override
+   public void onInitListener() throws MessageSystemException {
+   }
+
+   public IMessageSubscription getSubscription() {
+      return subscription;
+   }
+}