1 files changed, 142 insertions, 0 deletions
diff --git a/java/src/IceMX/ObserverFactory.java b/java/src/IceMX/ObserverFactory.java
new file mode 100644
index 00000000000..c1bf521985d
--- /dev/null
+++ b/java/src/IceMX/ObserverFactory.java
@@ -0,0 +1,142 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2012 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+package IceMX;
+
+import IceInternal.MetricsMap;
+
+public class ObserverFactory<T extends Metrics, O extends Observer<T>>
+{
+    public 
+    ObserverFactory(IceInternal.MetricsAdminI metrics, String name, Class<T> cl)
+    {
+        _metrics = metrics;
+        _name = name;
+        _class = cl;
+        _metrics.registerMap(name, _class, new Runnable() 
+            {
+                public void 
+                run()
+                {
+                    update();
+                }
+            });
+    }
+
+    public
+    ObserverFactory(String name, Class<T> cl)
+    {
+        _name = name;
+        _metrics = null;
+        _class = cl;
+    }
+
+    public void
+    destroy()
+    {
+        if(_metrics != null)
+        {
+            _metrics.unregisterMap(_name);
+        }
+    }
+
+    synchronized O
+    getObserver(MetricsHelper<T> helper, Class<O> cl)
+    {
+        return getObserver(helper, null, cl);
+    }
+
+    @SuppressWarnings("unchecked")
+    synchronized O
+    getObserver(MetricsHelper<T> helper, Object observer, Class<O> cl)
+    {
+
+        java.util.List<MetricsMap<T>.Entry> metricsObjects = new java.util.LinkedList<MetricsMap<T>.Entry>();
+        for(MetricsMap<T> m : _maps)
+        {
+            MetricsMap<T>.Entry e = m.getMatching(helper);
+            if(e != null)
+            {
+                metricsObjects.add(e);
+            }
+        }
+
+        if(metricsObjects.isEmpty())
+        {
+            return null;
+        }
+
+        O obsv;
+        if(observer == null)
+        {
+            try
+            {
+                obsv = cl.newInstance();
+            }
+            catch(Exception ex)
+            {
+                assert(false);
+                return null;
+            }
+            obsv.init(helper, metricsObjects);
+        }
+        else
+        {
+            obsv = (O)observer;
+            obsv.update(helper, metricsObjects);
+        }
+        return obsv;
+    }
+
+    public <S extends IceMX.Metrics> void
+    registerSubMap(String subMap, Class<S> cl, java.lang.reflect.Field field)
+    {
+        _metrics.registerSubMap(_name, subMap, cl, field);
+    }
+
+    public boolean
+    isEnabled()
+    {
+        return _enabled;
+    }
+
+    public void 
+    update()
+    {
+        Runnable updater;
+        synchronized(this)
+        {
+            _maps.clear();
+            for(MetricsMap<T> m : _metrics.getMaps(_name, _class))
+            {
+                _maps.add(m);
+            }
+            _enabled = !_maps.isEmpty();
+            updater = _updater;
+        }
+
+        if(updater != null)
+        {
+            updater.run();
+        }
+    }
+
+    synchronized void
+    setUpdater(Runnable updater)
+    {
+        _updater = updater;
+    }
+    
+    private final IceInternal.MetricsAdminI _metrics;
+    private final String _name;
+    private final Class<T> _class;
+    private java.util.List<MetricsMap<T>> _maps = new java.util.ArrayList<MetricsMap<T>>();
+    private volatile boolean _enabled;
+    private Runnable _updater;
+}
+\ No newline at end of file