X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=common%2Futil%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fyangtools%2Futil%2FListenerRegistry.java;h=32876f6885210f9e0f50d4bf8992d497a9b3d8ee;hb=refs%2Fchanges%2F99%2F46599%2F4;hp=e8b1a3dca975adbfbba831ace82a1045557c9af5;hpb=a0d9f509acb275e5f047e91dd8e18ea738baa1c8;p=yangtools.git diff --git a/common/util/src/main/java/org/opendaylight/yangtools/util/ListenerRegistry.java b/common/util/src/main/java/org/opendaylight/yangtools/util/ListenerRegistry.java index e8b1a3dca9..32876f6885 100644 --- a/common/util/src/main/java/org/opendaylight/yangtools/util/ListenerRegistry.java +++ b/common/util/src/main/java/org/opendaylight/yangtools/util/ListenerRegistry.java @@ -12,13 +12,14 @@ import java.util.Collections; import java.util.EventListener; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import org.opendaylight.yangtools.concepts.AbstractObjectRegistration; import org.opendaylight.yangtools.concepts.ListenerRegistration; public class ListenerRegistry implements Iterable> { - private final ConcurrentHashMap,ListenerRegistration> listeners; + private final ConcurrentMap,ListenerRegistration> listeners; final Set> unmodifiableView; @SuppressWarnings("unchecked") @@ -34,36 +35,35 @@ public class ListenerRegistry implements Iterable register(T listener) { + public ListenerRegistration register(final T listener) { if (listener == null) { throw new IllegalArgumentException("Listener should not be null."); } - ListenerRegistrationImpl ret = new ListenerRegistrationImpl(listener); + final ListenerRegistrationImpl ret = new ListenerRegistrationImpl<>(listener); listeners.put(ret,ret); return ret; } - - public ListenerRegistration registerWithType(L listener) { - ListenerRegistrationImpl ret = new ListenerRegistrationImpl(listener); + + public ListenerRegistration registerWithType(final L listener) { + final ListenerRegistrationImpl ret = new ListenerRegistrationImpl<>(listener); listeners.put(ret,ret); return ret; } - + @Override public java.util.Iterator> iterator() { return unmodifiableView.iterator(); } @SuppressWarnings("rawtypes") - private void remove(ListenerRegistrationImpl registration) { + private void remove(final ListenerRegistrationImpl registration) { listeners.remove(registration); } - private class ListenerRegistrationImpl

// - extends AbstractObjectRegistration

// - implements ListenerRegistration

{ + private class ListenerRegistrationImpl

extends AbstractObjectRegistration

implements + ListenerRegistration

{ - public ListenerRegistrationImpl(P instance) { + public ListenerRegistrationImpl(final P instance) { super(instance); }