You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2012/02/22 17:45:00 UTC
svn commit: r1292389 - in /camel/branches/camel-2.9.x: ./
camel-core/src/main/java/org/apache/camel/management/
camel-core/src/main/java/org/apache/camel/model/
camel-core/src/test/java/org/apache/camel/management/
Author: davsclaus
Date: Wed Feb 22 16:44:59 2012
New Revision: 1292389
URL: http://svn.apache.org/viewvc?rev=1292389&view=rev
Log:
CAMEL-5027: Fixed JMS stats for load balancer EIP
Added:
camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedLoadBalancerTest.java
- copied unchanged from r1292384, camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedLoadBalancerTest.java
camel/branches/camel-2.9.x/camel-core/src/test/java/org/apache/camel/management/ManagedMulticastTest.java
- copied unchanged from r1292384, camel/trunk/camel-core/src/test/java/org/apache/camel/management/ManagedMulticastTest.java
Modified:
camel/branches/camel-2.9.x/ (props changed)
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/DelegatePerformanceCounter.java
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/InstrumentationProcessor.java
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Wed Feb 22 16:44:59 2012
@@ -1 +1 @@
-/camel/trunk:1243046,1243057,1243234,1244518,1244644,1244859,1244861,1244864,1244870,1244872,1245021,1291555,1291727,1291848,1291864,1292114
+/camel/trunk:1243046,1243057,1243234,1244518,1244644,1244859,1244861,1244864,1244870,1244872,1245021,1291555,1291727,1291848,1291864,1292114,1292384
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/DelegatePerformanceCounter.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/DelegatePerformanceCounter.java?rev=1292389&r1=1292388&r2=1292389&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/DelegatePerformanceCounter.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/DelegatePerformanceCounter.java Wed Feb 22 16:44:59 2012
@@ -68,4 +68,9 @@ public class DelegatePerformanceCounter
this.statisticsEnabled = statisticsEnabled;
}
}
+
+ @Override
+ public String toString() {
+ return counter != null ? counter.toString() : super.toString();
+ }
}
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/InstrumentationProcessor.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/InstrumentationProcessor.java?rev=1292389&r1=1292388&r2=1292389&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/InstrumentationProcessor.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/management/InstrumentationProcessor.java Wed Feb 22 16:44:59 2012
@@ -80,6 +80,11 @@ public class InstrumentationProcessor ex
callback.done(doneSync);
}
}
+
+ @Override
+ public String toString() {
+ return InstrumentationProcessor.this.toString();
+ }
});
}
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java?rev=1292389&r1=1292388&r2=1292389&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java Wed Feb 22 16:44:59 2012
@@ -137,7 +137,7 @@ public class LoadBalanceDefinition exten
throw new IllegalArgumentException("Loadbalancer already configured to: " + loadBalancerType + ". Cannot set it to: " + processorType);
}
Processor processor = processorType.createProcessor(routeContext);
- processor = wrapProcessor(routeContext, processor);
+ processor = wrapChannel(routeContext, processor, processorType);
loadBalancer.addProcessor(processor);
}
return loadBalancer;