summaryrefslogtreecommitdiff
path: root/java/src/IceGrid/NodeObserverI.java
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2005-06-30 19:25:26 +0000
committerBernard Normier <bernard@zeroc.com>2005-06-30 19:25:26 +0000
commit685bc67bd5f7ee487ce4477a4b28815411aef2cd (patch)
tree572cfb9eed061fffc3f0d81143f005f700cd45fa /java/src/IceGrid/NodeObserverI.java
parentmore icons (diff)
downloadice-685bc67bd5f7ee487ce4477a4b28815411aef2cd.tar.bz2
ice-685bc67bd5f7ee487ce4477a4b28815411aef2cd.tar.xz
ice-685bc67bd5f7ee487ce4477a4b28815411aef2cd.zip
Observer implementation
Diffstat (limited to 'java/src/IceGrid/NodeObserverI.java')
-rwxr-xr-xjava/src/IceGrid/NodeObserverI.java53
1 files changed, 49 insertions, 4 deletions
diff --git a/java/src/IceGrid/NodeObserverI.java b/java/src/IceGrid/NodeObserverI.java
index 190c9b01bb5..2268c4fa9d4 100755
--- a/java/src/IceGrid/NodeObserverI.java
+++ b/java/src/IceGrid/NodeObserverI.java
@@ -8,6 +8,7 @@
// **********************************************************************
package IceGrid;
+import javax.swing.SwingUtilities;
class NodeObserverI extends _NodeObserverDisp
{
@@ -16,20 +17,64 @@ class NodeObserverI extends _NodeObserverDisp
_model = model;
}
- public void init(NodeDynamicInfo[] nodes, Ice.Current current)
+ public void init(final NodeDynamicInfo[] nodes, Ice.Current current)
{
+ SwingUtilities.invokeLater(new Runnable()
+ {
+ public void run()
+ {
+ for(int i = 0; i < nodes.length; ++i)
+ {
+ _model.nodeUp(nodes[i]);
+ }
+ }
+ });
}
- public void initNode(NodeDynamicInfo node, Ice.Current current)
+ public void nodeUp(final NodeDynamicInfo nodeInfo, Ice.Current current)
{
+ SwingUtilities.invokeLater(new Runnable()
+ {
+ public void run()
+ {
+ _model.nodeUp(nodeInfo);
+ }
+ });
}
- public void updateServer(String node, ServerDynamicInfo updatedInfo, Ice.Current current)
+ public void nodeDown(final String nodeName, Ice.Current current)
{
+ SwingUtilities.invokeLater(new Runnable()
+ {
+ public void run()
+ {
+ _model.nodeDown(nodeName);
+ }
+ });
}
- public void updateAdapter(String node, AdapterDynamicInfo updatedInfo, Ice.Current current)
+ public void updateServer(final String node, final ServerDynamicInfo updatedInfo,
+ Ice.Current current)
+ {
+ SwingUtilities.invokeLater(new Runnable()
+ {
+ public void run()
+ {
+ _model.updateServer(node, updatedInfo);
+ }
+ });
+ }
+
+ public void updateAdapter(final String node, final AdapterDynamicInfo updatedInfo,
+ Ice.Current current)
{
+ SwingUtilities.invokeLater(new Runnable()
+ {
+ public void run()
+ {
+ _model.updateAdapter(node, updatedInfo);
+ }
+ });
}
private Model _model;