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 2013/06/25 04:46:13 UTC
[1/2] git commit: Added some comments on the MyProcessor of camel-cxf
unit test
Updated Branches:
refs/heads/master ce1dbb4c8 -> c83e23c0c
Added some comments on the MyProcessor of camel-cxf unit test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/351d80e5
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/351d80e5
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/351d80e5
Branch: refs/heads/master
Commit: 351d80e55244aaad79ce8036ebc67115dbb68ae1
Parents: ce1dbb4
Author: Willem Jiang <ni...@apache.org>
Authored: Tue Jun 25 09:23:09 2013 +0800
Committer: Willem Jiang <ni...@apache.org>
Committed: Tue Jun 25 09:23:51 2013 +0800
----------------------------------------------------------------------
.../apache/camel/component/cxf/wssecurity/camel/MyProcessor.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/351d80e5/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/wssecurity/camel/MyProcessor.java
----------------------------------------------------------------------
diff --git a/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/wssecurity/camel/MyProcessor.java b/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/wssecurity/camel/MyProcessor.java
index 06bc461..c53f06d 100644
--- a/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/wssecurity/camel/MyProcessor.java
+++ b/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/wssecurity/camel/MyProcessor.java
@@ -8,6 +8,10 @@ import javax.xml.soap.SOAPMessage;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
+/**
+ * This processor is used to create a new SOAPMessage from the in message stream
+ * which will be used as output message.
+ */
public class MyProcessor implements Processor {
@Override
[2/2] git commit: CAMEL-6485 performance improvement in
DefaultCamelContext with thanks to Eric
Posted by ni...@apache.org.
CAMEL-6485 performance improvement in DefaultCamelContext with thanks to Eric
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c83e23c0
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c83e23c0
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c83e23c0
Branch: refs/heads/master
Commit: c83e23c0c6a937240a226f56fa63e62bc7ff31ac
Parents: 351d80e
Author: Willem Jiang <ni...@apache.org>
Authored: Tue Jun 25 09:40:02 2013 +0800
Committer: Willem Jiang <ni...@apache.org>
Committed: Tue Jun 25 09:40:02 2013 +0800
----------------------------------------------------------------------
.../java/org/apache/camel/impl/DefaultCamelContext.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/c83e23c0/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java b/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
index 22fa6e1..a276eac 100644
--- a/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
+++ b/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
@@ -2434,12 +2434,14 @@ public class DefaultCamelContext extends ServiceSupport implements ModelCamelCon
}
public ManagementStrategy getManagementStrategy() {
- synchronized (managementStrategyInitialized) {
- if (managementStrategyInitialized.compareAndSet(false, true)) {
- managementStrategy = createManagementStrategy();
+ if (!managementStrategyInitialized.get()) {
+ synchronized (managementStrategyInitialized) {
+ if (managementStrategyInitialized.compareAndSet(false, true)) {
+ managementStrategy = createManagementStrategy();
+ }
}
- return managementStrategy;
}
+ return managementStrategy;
}
public void setManagementStrategy(ManagementStrategy managementStrategy) {