Hi Guys,
Was just looking at how this works in the 2.2 version. One thing that struck me when looking at it was that i didnt see the clean up of the at the end of the run method. Maybe its getting called from outside the package but just thought i would mention it cause everything looks to be encapsulated in this class

So heres the run

 public void run()
 {
 int op;
 Fqn fqn;
 Object key, val, retval;
 NodeSPI n;
 boolean flag;
...........
 }
 output.flush();
 }
 catch (Exception e)
 {
 log.debug(e, e);
 try
 {
 output.writeObject(e);
 output.flush();
 }
 catch (IOException e1)
 {
 log.error(e1, e1);
 }
 }
 }