[284834] [Releng] Migrate Net4j and CDO builds to Athena/Hudson

https://bugs.eclipse.org/bugs/show_bug.cgi?id=284834

1 files changed, 38 insertions, 20 deletions

diff --git a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/session/remote/CDORemoteSessionManagerImpl.java b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/session/remote/CDORemoteSessionManagerImpl.java
index c975a7d0a9..39f97ccff1 100644
--- a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/session/remote/CDORemoteSessionManagerImpl.java
+++ b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/session/remote/CDORemoteSessionManagerImpl.java
@@ -199,33 +199,16 @@ public class CDORemoteSessionManagerImpl extends Container<CDORemoteSession> imp
     }
   }
 
-  public void handleRemoteSessionSubscribed(int sessionID, final boolean subscribed)
+  public void handleRemoteSessionSubscribed(int sessionID, boolean subscribed)
   {
     IEvent event = null;
     synchronized (this)
     {
-      final CDORemoteSessionManager source = this;
-      final InternalCDORemoteSession remoteSession = (InternalCDORemoteSession)remoteSessions.get(sessionID);
+      InternalCDORemoteSession remoteSession = (InternalCDORemoteSession)remoteSessions.get(sessionID);
       if (remoteSession != null)
       {
         remoteSession.setSubscribed(subscribed);
-        event = new CDORemoteSessionEvent.SubscriptionChanged()
-        {
-          public CDORemoteSessionManager getSource()
-          {
-            return source;
-          }
-
-          public CDORemoteSession getRemoteSession()
-          {
-            return remoteSession;
-          }
-
-          public boolean isSubscribed()
-          {
-            return subscribed;
-          }
-        };
+        event = new SubscriptionChangedEventImpl(remoteSession, subscribed);
       }
     }
 
@@ -372,4 +355,39 @@ public class CDORemoteSessionManagerImpl extends Container<CDORemoteSession> imp
       return subscribed;
     }
   }
+
+  /**
+   * @author Eike Stepper
+   */
+  private final class SubscriptionChangedEventImpl extends Event implements CDORemoteSessionEvent.SubscriptionChanged
+  {
+    private static final long serialVersionUID = 1L;
+
+    private InternalCDORemoteSession remoteSession;
+
+    private boolean subscribed;
+
+    public SubscriptionChangedEventImpl(InternalCDORemoteSession remoteSession, boolean subscribed)
+    {
+      super(CDORemoteSessionManagerImpl.this);
+      this.remoteSession = remoteSession;
+      this.subscribed = subscribed;
+    }
+
+    @Override
+    public CDORemoteSessionManager getSource()
+    {
+      return (CDORemoteSessionManager)super.getSource();
+    }
+
+    public CDORemoteSession getRemoteSession()
+    {
+      return remoteSession;
+    }
+
+    public boolean isSubscribed()
+    {
+      return subscribed;
+    }
+  }
 }