private final Persister storage;
private final boolean readOnly;
- public PersisterWithConfiguration(Persister storage, boolean readOnly) {
+ public PersisterWithConfiguration(final Persister storage, final boolean readOnly) {
this.storage = storage;
this.readOnly = readOnly;
}
*/
private final List<PersisterWithConfiguration> persisterWithConfigurations;
- public PersisterAggregator(List<PersisterWithConfiguration> persisterWithConfigurations) {
+ public PersisterAggregator(final List<PersisterWithConfiguration> persisterWithConfigurations) {
this.persisterWithConfigurations = persisterWithConfigurations;
}
}
}
- public static PersisterAggregator createFromProperties(PropertiesProvider propertiesProvider) {
+ public static PersisterAggregator createFromProperties(final PropertiesProvider propertiesProvider) {
List<PersisterWithConfiguration> persisterWithConfigurations = new ArrayList<>();
String prefixes = propertiesProvider.getProperty("active");
if (prefixes!=null && !prefixes.isEmpty()) {
}
@Override
- public void persistConfig(ConfigSnapshotHolder holder) throws IOException {
+ public void persistConfig(final ConfigSnapshotHolder holder) throws IOException {
for (PersisterWithConfiguration persisterWithConfiguration: persisterWithConfigurations){
if (!persisterWithConfiguration.readOnly){
LOG.debug("Calling {}.persistConfig", persisterWithConfiguration.getStorage());
List<ConfigSnapshotHolder> configs = null;
try {
configs = persisterWithConfiguration.storage.loadLastConfigs();
- } catch (IOException e) {
+ } catch (final IOException e) {
throw new RuntimeException("Error while calling loadLastConfig on " + persisterWithConfiguration, e);
}
if (!configs.isEmpty()) {
for (PersisterWithConfiguration persisterWithConfiguration: persisterWithConfigurations){
try{
persisterWithConfiguration.storage.close();
- }catch(RuntimeException e) {
+ }catch(final RuntimeException e) {
LOG.error("Error while closing {}", persisterWithConfiguration.storage, e);
if (lastException == null){
lastException = e;