X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=support%2Fgeneral%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fobserver%2FObservable.java;h=5c2e9a4f2ca5fe5c51710d568af35bc100fd669b;hb=5e33a52ba36ac928b9863ddd79d2d09f6a308af6;hp=096b0600043f726d9bdc493f83d3aacbe2e19d78;hpb=ddd261f331280640c5b53c7128230b629ebcd268;p=utils diff --git a/support/general/src/main/java/org/wamblee/observer/Observable.java b/support/general/src/main/java/org/wamblee/observer/Observable.java index 096b0600..5c2e9a4f 100644 --- a/support/general/src/main/java/org/wamblee/observer/Observable.java +++ b/support/general/src/main/java/org/wamblee/observer/Observable.java @@ -1,18 +1,18 @@ /* - * Copyright 2005 the original author or authors. - * + * Copyright 2005-2010 the original author or authors. + * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. - */ + */ package org.wamblee.observer; import org.apache.log4j.Logger; @@ -22,7 +22,6 @@ import java.util.List; import java.util.Map; import java.util.TreeMap; - /** * Implements subscription and notification logic for an observer pattern. This * class is thread safe. @@ -52,7 +51,7 @@ public class Observable { /** * Constructs the observable. - * + * * @param aObservable * Observable this instance is used for. * @param aNotifier @@ -68,15 +67,14 @@ public class Observable { /** * Subscribe an obvers. - * + * * @param aObserver * Observer to subscribe. * @return Event Event to send. */ - public synchronized long subscribe( - Observer aObserver) { + public synchronized long subscribe(Observer aObserver) { long subscription = counter++; // integer rage is so large it will - // never roll over. + // never roll over. observers.put(subscription, aObserver); @@ -85,7 +83,7 @@ public class Observable { /** * Unsubscribe an observer. - * + * * @param aSubscription * Subscription which is used * @throws IllegalArgumentException @@ -102,7 +100,7 @@ public class Observable { /** * Gets the number of subscribed observers. - * + * * @return Number of subscribed observers. */ public int getObserverCount() { @@ -111,7 +109,7 @@ public class Observable { /** * Notifies all subscribed observers. - * + * * @param aEvent * Event to send. */ @@ -129,23 +127,4 @@ public class Observable { notifier.update(observer, observable, aEvent); } } - - /* - * (non-Javadoc) - * - * @see java.lang.Object#finalize() - */ - @Override - protected void finalize() throws Throwable { - if (observers.size() > 0) { - LOGGER.error( - "Still observers registered at finalization of observer!"); - - for (Observer observer : observers.values()) { - LOGGER.error(" observer: " + observer); - } - } - - super.finalize(); - } }