From b086f57f56bf0eb9dab9cf321a0f69aaaae84347 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Wed, 30 May 2012 08:37:45 +0200
Subject: Initial Maven Conversion

---
 .../c2kernel/entity/proxy/MemberSubscription.java  | 118 ---------------------
 1 file changed, 118 deletions(-)
 delete mode 100644 source/com/c2kernel/entity/proxy/MemberSubscription.java

(limited to 'source/com/c2kernel/entity/proxy/MemberSubscription.java')

diff --git a/source/com/c2kernel/entity/proxy/MemberSubscription.java b/source/com/c2kernel/entity/proxy/MemberSubscription.java
deleted file mode 100644
index 157297f..0000000
--- a/source/com/c2kernel/entity/proxy/MemberSubscription.java
+++ /dev/null
@@ -1,118 +0,0 @@
-
-package com.c2kernel.entity.proxy;
-import java.lang.ref.WeakReference;
-import java.util.ArrayList;
-import java.util.StringTokenizer;
-
-import com.c2kernel.common.ObjectNotFoundException;
-import com.c2kernel.entity.C2KLocalObject;
-import com.c2kernel.utils.Logger;
-
-public class MemberSubscription<C extends C2KLocalObject> implements Runnable {
-	public static final String ERROR = "Error";
-	public static final String END = "theEND";
-	
-    EntityProxy subject;
-    String interest;
-    // keep the subscriber by weak reference, so it is not kept from the garbage collector if no longer used
-    WeakReference<EntityProxyObserver<C>> observerReference;
-    ArrayList<String> contents = new ArrayList<String>();
-    boolean preLoad;
-
-    public MemberSubscription(EntityProxyObserver<C> observer, String interest, boolean preLoad) {
-        setObserver(observer);
-        this.interest = interest;
-        this.preLoad = preLoad;
-    }
-
-    @Override
-	public void run() {
-        Thread.currentThread().setName("Member Subscription: "+subject.getSystemKey()+":"+interest);
-        if (preLoad) loadChildren();
-    }
-
-    private void loadChildren() {
-        C newMember;
-        EntityProxyObserver<C> observer = getObserver();
-        if (observer == null) return; //reaped
-        try {
-            // fetch contents of path
-            String children = subject.queryData(interest+"/all");
-            StringTokenizer tok = new StringTokenizer(children, ",");
-            ArrayList<String> newContents = new ArrayList<String>();
-            while (tok.hasMoreTokens())
-                newContents.add(tok.nextToken());
-
-            // look to see what's new
-            for (String newChild: newContents) {
-
-                // load child object
-                try {
-                    newMember = (C)subject.getObject(interest+"/"+newChild);
-                    contents.remove(newChild);
-                    observer.add(newMember);
-                } catch (ObjectNotFoundException ex) {
-                    observer.control(ERROR, "Listed member "+newChild+" was not found.");
-                }
-            }
-            // report what's left in old contents as deleted
-            for (String oldChild: contents) {
-                observer.remove(interest+"/"+oldChild);
-            }
-            //replace contents arraylist
-            contents = newContents;
-            //report that we're done
-            observer.control(END, null);
-        } catch (Exception ex) {
-            observer.control(ERROR, "Query on "+interest+" failed with "+ex);
-        }
-    }
-
-    public boolean isRelevant(String path) {
-        Logger.msg(7, "Checking relevance of "+path+" to "+interest);
-        return (path.startsWith(interest));
-    }
-
-    public void update(String path, boolean deleted) {
-        EntityProxyObserver<C> observer = getObserver();
-        if (observer == null) return; //reaped
-        Logger.msg(7, "Processing proxy message path "+path +" for "+observer+". Interest: "+interest+" Was Deleted:"+deleted);
-        if (!path.startsWith(interest)) // doesn't concern us
-           return;
-
-        if (path.equals(interest)) // refresh contents
-           loadChildren();
-        else {
-            String name = path.substring(interest.length());
-            if (deleted) {
-                Logger.msg(4, "Removing "+path);
-                contents.remove(name);
-                observer.remove(name);
-            }
-            else {
-                try {
-                    C newMember = (C)subject.getObject(path);
-                    Logger.msg(4, "Adding "+path);
-                    contents.add(name);
-                    observer.add(newMember);
-                } catch (ObjectNotFoundException e) {
-                    Logger.error("Member Subscription: could not load "+path);
-                    Logger.error(e);
-                }
-            }
-        }
-    }
-
-    public void setObserver(EntityProxyObserver<C> observer) {
-        observerReference = new WeakReference<EntityProxyObserver<C>>(observer);
-    }
-    
-    public void setSubject(EntityProxy subject) {
-    	this.subject = subject;
-    }
-
-    public EntityProxyObserver<C> getObserver() {
-        return observerReference.get();
-    }
-}
-
-- 
cgit v1.2.3