log.error("-- received EXIT, waiting for ChannelReconnected callback");
System.err.println("-- received EXIT, waiting for ChannelReconnected callback");
            public void run() {               Object tmp;               while (! closed) {                  try {                     tmp = channel.receive(0);                     if (tmp instanceof ExitEvent) {                        log.error("-- received EXIT, waiting for ChannelReconnected callback");                        break;                     }                     if (tmp instanceof GetStateEvent) {                        synchronized (Coordinator.this) {                           log.error("--  GetStateEvent, cnt=" + cnt);                           channel.returnState(Util.objectToByteBuffer(new Integer(cnt)));                        }                        continue;                     }                  } catch (ChannelNotConnectedException not) {                     break;                  } catch (ChannelClosedException closed) {                     break;                  } catch (Exception e) {                     log.error(e);                     continue;                  }               }            }