svn commit: r1654477 - /sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/agent/impl/SyncDistributionAgentFactory.java

[mpetria]

Author: mpetria
Date: Sat Jan 24 07:01:59 2015
New Revision: 1654477

URL: http://svn.apache.org/r1654477
Log:
SLING-4348: enabling queue processing for sync agents

Modified:
    
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/agent/impl/SyncDistributionAgentFactory.java

Modified: 
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/agent/impl/SyncDistributionAgentFactory.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/agent/impl/SyncDistributionAgentFactory.java?rev=1654477&r1=1654476&r2=1654477&view=diff
==============================================================================
--- 
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/agent/impl/SyncDistributionAgentFactory.java
 (original)
+++ 
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/agent/impl/SyncDistributionAgentFactory.java
 Sat Jan 24 07:01:59 2015
@@ -79,6 +79,9 @@ public class SyncDistributionAgentFactor
     @Property(label = "Service Name", description = "The name of the service 
used to access the repository.")
     public static final String SERVICE_NAME = "serviceName";
 
+    @Property(boolValue = true, label = "Queue Processing Enabled", 
description = "Whether or not the distribution agent should process packages in 
the queues.")
+    public static final String QUEUE_PROCESSING_ENABLED = 
"queue.processing.enabled";
+
     /**
      * endpoints property
      */
@@ -158,6 +161,8 @@ public class SyncDistributionAgentFactor
     @Override
     protected SimpleDistributionAgent createAgent(String agentName, 
BundleContext context, Map<String, Object> config) {
         String serviceName = PropertiesUtil.toString(config.get(SERVICE_NAME), 
null);
+        boolean queueProcessingEnabled = 
PropertiesUtil.toBoolean(config.get(QUEUE_PROCESSING_ENABLED), true);
+
 
 
         Object exporterEndpointsValue = config.get(EXPORTER_ENDPOINTS);
@@ -184,7 +189,7 @@ public class SyncDistributionAgentFactor
         DistributionPackageExporter packageExporter = new 
RemoteDistributionPackageExporter(packageBuilder, transportSecretProvider, 
exporterEndpoints, TransportEndpointStrategyType.All, 1);
         DistributionQueueProvider queueProvider =  new 
JobHandlingDistributionQueueProvider(agentName, jobManager, context);
 
-        return new SimpleDistributionAgent(agentName, false, serviceName,
+        return new SimpleDistributionAgent(agentName, queueProcessingEnabled, 
serviceName,
                 packageImporter, packageExporter, requestAuthorizationStrategy,
                 queueProvider, dispatchingStrategy, distributionEventFactory, 
resourceResolverFactory);