You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2012/08/28 04:45:05 UTC
svn commit: r1377952 - in
/camel/trunk/camel-core/src/main/java/org/apache/camel:
management/DefaultManagementLifecycleStrategy.java
processor/loadbalancer/RandomLoadBalancer.java
Author: ningjiang
Date: Tue Aug 28 02:45:05 2012
New Revision: 1377952
URL: http://svn.apache.org/viewvc?rev=1377952&view=rev
Log:
Polished the codes of camel-core
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/RandomLoadBalancer.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java?rev=1377952&r1=1377951&r2=1377952&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/management/DefaultManagementLifecycleStrategy.java Tue Aug 28 02:45:05 2012
@@ -855,7 +855,7 @@ public class DefaultManagementLifecycleS
@Override
public void onCamelContextStarted(CamelContext context, boolean alreadyStarted) throws Exception {
// we are disabled either if configured explicit, or if level is off
- boolean disabled = camelContext.getManagementStrategy().isLoadStatisticsEnabled() == false
+ boolean disabled = !camelContext.getManagementStrategy().isLoadStatisticsEnabled()
|| camelContext.getManagementStrategy().getStatisticsLevel() == ManagementStatisticsLevel.Off;
if (!disabled) {
LOG.info("Load performance statistics enabled.");
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/RandomLoadBalancer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/RandomLoadBalancer.java?rev=1377952&r1=1377951&r2=1377952&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/RandomLoadBalancer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/loadbalancer/RandomLoadBalancer.java Tue Aug 28 02:45:05 2012
@@ -29,7 +29,7 @@ import org.apache.camel.Processor;
*/
public class RandomLoadBalancer extends QueueLoadBalancer {
- private static final Random random = new Random();
+ private static final Random RANDOM = new Random();
protected synchronized Processor chooseProcessor(List<Processor> processors, Exchange exchange) {
int size = processors.size();
@@ -41,7 +41,7 @@ public class RandomLoadBalancer extends
}
// pick a random
- int index = random.nextInt(size);
+ int index = RANDOM.nextInt(size);
return processors.get(index);
}