public void testReconciliationFlushTriggeredByMemberCrashing() throws Exception {
FlushTrigger t = new FlushTrigger() {
public void triggerFlush() {
JChannel channel = channels.remove(channels.size() - 1);
channel.shutdown();
};
};
String apps[] = createApplicationNames(3);
reconciliationHelper(apps, t);
}