- if(!interuppted) {
- if(toInstall.isEmpty()) {
- event = queue.take();
- } else {
- event = queue.poll(POLL_TIME, TimeUnit.MILLISECONDS);
- }
- if(event != null && event.getFeature() !=null) {
- processFeatureEvent(event,toInstall);
- }
- } else if(toInstall.isEmpty()) {
- logger.error("ConfigPushingRunnable - exiting");
+ if (!interrupted) {
+ if (toInstall.isEmpty()) {
+ event = queue.take();
+ } else {
+ event = queue.poll(POLL_TIME, TimeUnit.MILLISECONDS);
+ }
+ if (event != null && event.getFeature() != null) {
+ processFeatureEvent(event, toInstall);
+ }
+ } else if (toInstall.isEmpty()) {
+ LOG.error("ConfigPushingRunnable - exiting");