You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cz...@apache.org on 2010/10/14 16:28:40 UTC
svn commit: r1022544 - in
/sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs:
config/InternalQueueConfiguration.java console/WebConsolePlugin.java
Author: cziegeler
Date: Thu Oct 14 14:28:40 2010
New Revision: 1022544
URL: http://svn.apache.org/viewvc?rev=1022544&view=rev
Log:
-1 is allowed for retries
Modified:
sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/config/InternalQueueConfiguration.java
sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/console/WebConsolePlugin.java
Modified: sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/config/InternalQueueConfiguration.java
URL: http://svn.apache.org/viewvc/sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/config/InternalQueueConfiguration.java?rev=1022544&r1=1022543&r2=1022544&view=diff
==============================================================================
--- sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/config/InternalQueueConfiguration.java (original)
+++ sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/config/InternalQueueConfiguration.java Thu Oct 14 14:28:40 2010
@@ -250,7 +250,7 @@ public class InternalQueueConfiguration
if ( name == null || name.length() == 0 ) {
return false;
}
- if ( retries < 0 ) {
+ if ( retries < -1 ) {
return false;
}
if ( type == Type.UNORDERED || type == Type.TOPIC_ROUND_ROBIN ) {
Modified: sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/console/WebConsolePlugin.java
URL: http://svn.apache.org/viewvc/sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/console/WebConsolePlugin.java?rev=1022544&r1=1022543&r2=1022544&view=diff
==============================================================================
--- sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/console/WebConsolePlugin.java (original)
+++ sling/branches/eventing-3.0/src/main/java/org/apache/sling/event/impl/jobs/console/WebConsolePlugin.java Thu Oct 14 14:28:40 2010
@@ -225,10 +225,10 @@ public class WebConsolePlugin extends Ht
pw.printf("<tr><td>Max Parallel</td><td>%s</td></tr>", c.getMaxParallel());
pw.printf("<tr><td>Max Retries</td><td>%s</td></tr>", c.getMaxRetries());
pw.printf("<tr><td>Retry Delay</td><td>%s ms</td></tr>", c.getRetryDelayInMs());
- pw.printf("<tr><td>Priority</td><td>%s ms</td></tr>", c.getPriority());
- pw.printf("<tr><td>Run Local</td><td>%s ms</td></tr>", c.isLocalQueue());
- pw.printf("<tr><td>App Ids</td><td>%s ms</td></tr>", formatArray(c.getApplicationIds()));
- pw.printf("<tr><td>Ranking</td><td>%s ms</td></tr>", c.getRanking());
+ pw.printf("<tr><td>Priority</td><td>%s</td></tr>", c.getPriority());
+ pw.printf("<tr><td>Run Local</td><td>%s</td></tr>", c.isLocalQueue());
+ pw.printf("<tr><td>App Ids</td><td>%s</td></tr>", formatArray(c.getApplicationIds()));
+ pw.printf("<tr><td>Ranking</td><td>%s</td></tr>", c.getRanking());
pw.println("</tbody></table>");
pw.println("<br/>");
@@ -406,10 +406,10 @@ public class WebConsolePlugin extends Ht
pw.printf("Max Parallel : %s%n", c.getMaxParallel());
pw.printf("Max Retries : %s%n", c.getMaxRetries());
pw.printf("Retry Delay : %s ms%n", c.getRetryDelayInMs());
- pw.printf("Priority : %s ms%n", c.getPriority());
- pw.printf("Run Local : %s ms%n", c.isLocalQueue());
- pw.printf("App Ids : %s ms%n", formatArrayAsText(c.getApplicationIds()));
- pw.printf("Ranking : %s ms%n", c.getRanking());
+ pw.printf("Priority : %s%n", c.getPriority());
+ pw.printf("Run Local : %s%n", c.isLocalQueue());
+ pw.printf("App Ids : %s%n", formatArrayAsText(c.getApplicationIds()));
+ pw.printf("Ranking : %s%n", c.getRanking());
pw.println();
}