svn commit: r1654776 [2/2] - in /sling/trunk/contrib/extensions/distribution: core/src/main/java/org/apache/sling/distribution/agent/ core/src/main/java/org/apache/sling/distribution/agent/impl/ core/src/main/java/org/apache/sling/distribution/componen...

[mpetria]

Modified: 
sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionAgentResourcesIntegrationTest.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionAgentResourcesIntegrationTest.java?rev=1654776&r1=1654775&r2=1654776&view=diff
==============================================================================
--- 
sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionAgentResourcesIntegrationTest.java
 (original)
+++ 
sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionAgentResourcesIntegrationTest.java
 Mon Jan 26 12:24:21 2015
@@ -30,6 +30,7 @@ import static org.apache.sling.distribut
 import static 
org.apache.sling.distribution.it.DistributionUtils.assertResponseContains;
 import static 
org.apache.sling.distribution.it.DistributionUtils.authorAgentConfigUrl;
 import static org.apache.sling.distribution.it.DistributionUtils.deleteNode;
+import static org.apache.sling.distribution.it.DistributionUtils.logUrl;
 import static 
org.apache.sling.distribution.it.DistributionUtils.publishAgentConfigUrl;
 import static org.apache.sling.distribution.it.DistributionUtils.queueUrl;
 
@@ -94,6 +95,30 @@ public class DistributionAgentResourcesI
         }
     }
 
+    @Test
+    public void testDefaultAuthorAgentLogResources() throws Exception {
+        // these agent queues exist as they are bundled to author runMode
+        String[] defaultAuthorAgentNames = new String[]{
+                "publish",
+                "publish-reverse"
+        };
+        for (String agentName : defaultAuthorAgentNames) {
+            assertExists(authorClient, logUrl(agentName));
+        }
+    }
+
+
+
+    @Test
+    public void testDefaultPublishAgentLogResources() throws Exception {
+        // these agent queues do not exist as they are bundled to publish 
runMode
+        String[] defaultPublishAgentNames = new String[]{
+                "reverse"        };
+        for (String agentName : defaultPublishAgentNames) {
+            assertNotExists(authorClient, logUrl(agentName));
+        }
+    }
+
     @Test
     public void testDefaultAuthorAgentQueueResources() throws Exception {
         // these agent queues exist as they are bundled to author runMode

Modified: 
sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionUtils.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionUtils.java?rev=1654776&r1=1654775&r2=1654776&view=diff
==============================================================================
--- 
sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionUtils.java
 (original)
+++ 
sling/trunk/contrib/extensions/distribution/it/src/test/java/org/apache/sling/distribution/it/DistributionUtils.java
 Mon Jan 26 12:24:21 2015
@@ -219,6 +219,10 @@ public class DistributionUtils {
         return agentUrl(agentName) + "/queues";
     }
 
+    public static String logUrl(String agentName) {
+        return agentUrl(agentName) + "/log";
+    }
+
     public static String authorAgentConfigUrl(String agentName) {
         return DISTRIBUTION_ROOT_PATH + "/settings/agents/" + agentName;
     }