camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [4/6] camel git commit: CAMEL-10215: Fixed CS. This closes #1099
Date Tue, 02 Aug 2016 06:49:22 GMT
CAMEL-10215: Fixed CS. This closes #1099


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3add2eaa
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3add2eaa
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3add2eaa

Branch: refs/heads/camel-2.17.x
Commit: 3add2eaa21e425985da0aabde3b7426e7c8ddebb
Parents: 495bcfe
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Tue Aug 2 08:48:13 2016 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Tue Aug 2 08:48:45 2016 +0200

----------------------------------------------------------------------
 .../org/apache/camel/impl/EventDrivenPollingConsumer.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/3add2eaa/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
b/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
index 117598f..4e02b66 100644
--- a/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
+++ b/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java
@@ -114,8 +114,8 @@ public class EventDrivenPollingConsumer extends PollingConsumerSupport
implement
         }
 
         while (isRunAllowed()) {
-            // CAMEL-10215 - Synchronizing the ordering of beforePoll, poll and afterPoll
as an atomic activity
-            synchronized(this) {
+            // synchronizing the ordering of beforePoll, poll and afterPoll as an atomic
activity
+            synchronized (this) {
                 try {
                     beforePoll(0);
                     // take will block waiting for message
@@ -137,8 +137,8 @@ public class EventDrivenPollingConsumer extends PollingConsumerSupport
implement
             throw new RejectedExecutionException(this + " is not started, but in state: "
+ getStatus().name());
         }
 
-        // CAMEL-10215 - Synchronizing the ordering of beforePoll, poll and afterPoll as
an atomic activity
-        synchronized(this) {
+        // synchronizing the ordering of beforePoll, poll and afterPoll as an atomic activity
+        synchronized (this) {
             try {
                 // use the timeout value returned from beforePoll
                 timeout = beforePoll(timeout);


Mime
View raw message