X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=support%2Fgeneral%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fobserver%2FObservable.java;h=f31ba0dc485d1b839ceb8e354c9d0d0e15f657e5;hb=4a575582a5c2999bd816b197d9cf274b4b3ddcd7;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..f31ba0dc 100644 --- a/support/general/src/main/java/org/wamblee/observer/Observable.java +++ b/support/general/src/main/java/org/wamblee/observer/Observable.java @@ -1,12 +1,12 @@ /* - * 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. @@ -15,21 +15,16 @@ */ package org.wamblee.observer; -import org.apache.log4j.Logger; - import java.util.ArrayList; 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. */ public class Observable { - private static final Logger LOGGER = Logger.getLogger(Observable.class); - /** * Observable. */ @@ -52,7 +47,7 @@ public class Observable { /** * Constructs the observable. - * + * * @param aObservable * Observable this instance is used for. * @param aNotifier @@ -68,15 +63,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 +79,7 @@ public class Observable { /** * Unsubscribe an observer. - * + * * @param aSubscription * Subscription which is used * @throws IllegalArgumentException @@ -102,7 +96,7 @@ public class Observable { /** * Gets the number of subscribed observers. - * + * * @return Number of subscribed observers. */ public int getObserverCount() { @@ -111,7 +105,7 @@ public class Observable { /** * Notifies all subscribed observers. - * + * * @param aEvent * Event to send. */ @@ -129,23 +123,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(); - } }