125126127128129130131132133
isInClosed.set(true); t.interrupt(); // make sure the ping thread is terminated } }); t.start(); LOGGER.fine("Ping thread started for " + channel + " with a " + interval + " minute interval"); } }
103104105106107108109110111112113
@Override protected void onDead() { onDead(null); } }; ping.start(); main(channel); channel.join(); ping.interrupt(); } finally { // publish that we are done
979899100101102103104105106107
// this can never happen throw new AssertionError(e); } } }; ping.start(); main(channel); channel.join(); ping.interrupt(); } finally { // publish that we are done