import com.google.common.util.concurrent.ThreadFactoryBuilder;
import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
LOG.trace("AddingBundle for {} and event {} finished successfully",bundle,event);
return primaryTrackerRetVal;
} catch (Exception e) {
- LOG.error("Failed to add bundle ",e);
+ LOG.error("Failed to add bundle {}", bundle, e);
throw e;
}
}
}
});
LOG.trace("Removed bundle event for {} finished successfully.",bundle);
- } catch (InterruptedException | ExecutionException e) {
- LOG.error("Addition of bundle failed, ", e);
+ } catch (Exception e) {
+ LOG.error("Failed to remove bundle {}", bundle, e);
}
}