You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/08/24 09:36:26 UTC
[5/7] camel git commit: CAMEL-8010:Fixed checkstyle
CAMEL-8010:Fixed checkstyle
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e419e2d1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e419e2d1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e419e2d1
Branch: refs/heads/master
Commit: e419e2d1def4a92f3a869ec3780ef80ff8da166d
Parents: 094af05
Author: Rajithamol <rl...@mediaocean.com>
Authored: Tue Aug 22 12:09:25 2017 -0400
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Thu Aug 24 11:18:48 2017 +0200
----------------------------------------------------------------------
.../apache/camel/processor/aggregate/AggregateProcessor.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/e419e2d1/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
index c05b970..fe422da 100644
--- a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
+++ b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
@@ -1223,7 +1223,7 @@ public class AggregateProcessor extends ServiceSupport implements AsyncProcessor
LOG.info("We are shutting down so stop recovering");
return;
}
- if(!optimisticLocking){
+ if (!optimisticLocking) {
lock.lock();
}
try {
@@ -1288,9 +1288,8 @@ public class AggregateProcessor extends ServiceSupport implements AsyncProcessor
}
}
}
- }
- finally {
- if(!optimisticLocking){
+ } finally {
+ if (!optimisticLocking) {
lock.unlock();
}
}