Author: tommaso
Date: Wed Jan 15 13:57:12 2014
New Revision: 1558385
URL: http://svn.apache.org/r1558385
Log:
SLING-3318 - fixed initialization of queue providers
Modified:
sling/trunk/contrib/extensions/replication/src/main/java/org/apache/sling/replication/monitor/ReplicationQueueHealthCheck.java
Modified:
sling/trunk/contrib/extensions/replication/src/main/java/org/apache/sling/replication/monitor/ReplicationQueueHealthCheck.java
URL:
http://svn.apache.org/viewvc/sling/trunk/contrib/extensions/replication/src/main/java/org/apache/sling/replication/monitor/ReplicationQueueHealthCheck.java?rev=1558385&r1=1558384&r2=1558385&view=diff
==============================================================================
---
sling/trunk/contrib/extensions/replication/src/main/java/org/apache/sling/replication/monitor/ReplicationQueueHealthCheck.java
(original)
+++
sling/trunk/contrib/extensions/replication/src/main/java/org/apache/sling/replication/monitor/ReplicationQueueHealthCheck.java
Wed Jan 15 13:57:12 2014
@@ -77,11 +77,10 @@ public class ReplicationQueueHealthCheck
@Property(intValue = DEFAULT_NUMBER_OF_RETRIES_ALLOWED, description =
"Number of allowed retries", label = "Allowed retries")
private static final String NUMBER_OF_RETRIES_ALLOWED =
"numberOfRetriesAllowed";
- private Collection<ReplicationQueueProvider> replicationQueueProviders;
+ private final Collection<ReplicationQueueProvider>
replicationQueueProviders = new LinkedList<ReplicationQueueProvider>();
@Activate
public void activate(final Map<String, Object> properties) {
- replicationQueueProviders = new LinkedList<ReplicationQueueProvider>();
numberOfRetriesAllowed =
PropertiesUtil.toInteger(properties.get(NUMBER_OF_RETRIES_ALLOWED),
DEFAULT_NUMBER_OF_RETRIES_ALLOWED);
log.info("Activated, numberOfRetriesAllowed={}",
numberOfRetriesAllowed);
}