import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
-import java.util.Optional;
import java.util.function.Consumer;
String id;
@Autowired
Consumer<ConsumerRecord<K, V>> handler;
- @Autowired
- ApplicationErrorHandler errorHandler;
private long consumed = 0;
throw new IllegalStateException("Consumer instance " + id + " is already running!");
log.info("{} - Starting - consumed {} messages before", id, consumed);
- errorHandler.clearException();
registry.getListenerContainer(id).start();
}
log.info("{} - Stopped - consumed {} messages so far", id, consumed);
}
- public synchronized Optional<Exception> exitStatus()
+ public synchronized boolean isRunning()
{
- if (registry.getListenerContainer(id).isChildRunning())
- throw new IllegalStateException("No exit-status available: Consumer instance " + id + " is running!");
-
- return errorHandler.getException();
+ return registry.getListenerContainer(id).isChildRunning();
}
}