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 2014/06/10 14:28:23 UTC
[3/4] git commit: Polished
Polished
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fc23b55b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fc23b55b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fc23b55b
Branch: refs/heads/master
Commit: fc23b55bcc7817bef08e20a584094f53300ae137
Parents: f6fe643
Author: Claus Ibsen <da...@apache.org>
Authored: Tue Jun 10 14:19:03 2014 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Tue Jun 10 14:19:03 2014 +0200
----------------------------------------------------------------------
.../org/apache/camel/component/mybatis/MyBatisEndpoint.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/fc23b55b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java
index ae8511d..ea944ce 100644
--- a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java
+++ b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java
@@ -35,7 +35,7 @@ import org.apache.ibatis.session.SqlSessionFactory;
@UriEndpoint(scheme = "mybatis", consumerClass = MyBatisConsumer.class)
public class MyBatisEndpoint extends DefaultPollingEndpoint {
- private MyBatisProcessingStrategy processingStrategy;
+ private MyBatisProcessingStrategy processingStrategy = new DefaultMyBatisProcessingStrategy();
@UriParam
private String statement;
private StatementType statementType;
@@ -106,10 +106,7 @@ public class MyBatisEndpoint extends DefaultPollingEndpoint {
this.executorType = ExecutorType.valueOf(executorType.toUpperCase());
}
- public synchronized MyBatisProcessingStrategy getProcessingStrategy() {
- if (processingStrategy == null) {
- processingStrategy = new DefaultMyBatisProcessingStrategy();
- }
+ public MyBatisProcessingStrategy getProcessingStrategy() {
return processingStrategy;
}