executor.shutdown();
connectionManager.shutdown();
}
private void initializeConsumer() {
String node = configuration.getPath();
<BUG>if (configuration.listChildren()) {
</BUG>
initializeChildListingConsumer(node);
} else {
initializeDataConsumer(node);

executor.shutdown();
connectionManager.shutdown();
}
private void initializeConsumer() {
String node = configuration.getPath();
if (configuration.isListChildren()) {
initializeChildListingConsumer(node);
} else {
initializeDataConsumer(node);
