Repository: camel Updated Branches: refs/heads/master 5a4d6c6a6 -> 24a5cd751
Polished Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/24a5cd75 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/24a5cd75 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/24a5cd75 Branch: refs/heads/master Commit: 24a5cd75120672ee3b350bf3e7b93bf39a97ea31 Parents: 5a4d6c6 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Jul 31 15:51:18 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Jul 31 15:51:18 2017 +0200 ---------------------------------------------------------------------- .../component/reactive/streams/engine/CamelSubscription.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/24a5cd75/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java ---------------------------------------------------------------------- diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java index d7e17c8..638c06f 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java @@ -58,9 +58,9 @@ public class CamelSubscription implements Subscription { /** * The lock is used just for the time necessary to read/write shared variables. */ - private Lock mutex = new ReentrantLock(true); + private final Lock mutex = new ReentrantLock(true); - private LinkedList<Exchange> buffer = new LinkedList<>(); + private final LinkedList<Exchange> buffer = new LinkedList<>(); /** * The current number of exchanges requested by the subscriber.
