@Override
public void run() {
- List<Feature> toInstall = new ArrayList<Feature>();
- FeatureEvent event;
+ List<Feature> toInstall = new ArrayList<>();
+ FeatureEvent event = null;
boolean interuppted = false;
while(true) {
try {
LOG.error("ConfigPushingRunnable - interupted");
interuppted = true;
} catch (Exception e) {
- LOG.error("Exception while processing features ", e);
+ LOG.error("Exception while processing features {} event {}", toInstall, event, e);
}
}
}
- protected void processFeatureEvent(FeatureEvent event, List<Feature> toInstall) throws InterruptedException, Exception {
+ protected void processFeatureEvent(FeatureEvent event, List<Feature> toInstall) throws Exception {
if(event.getType() == EventType.FeatureInstalled) {
toInstall.add(event.getFeature());
LinkedHashMultimap<Feature,FeatureConfigSnapshotHolder> result = configPusher.pushConfigs(toInstall);