log.error("send cnt=" + cnt);
System.err.println("send cnt=" + cnt);
            public void run() {               while (! closed) {                  try {                     synchronized (Coordinator.this) {                        channel.send(null, null, new Integer(++cnt));                        log.error("send cnt=" + cnt);                     }                     Thread.sleep(1000);                  } catch (ChannelNotConnectedException not) {                     break;                  } catch (ChannelClosedException closed) {                     break;                  } catch (Exception e) {                     log.error(e);                     continue;                  }               }            }