Repository: curator Updated Branches: refs/heads/master d502dde1c -> 6d36a4793
Remove calls to deprecated MoreExecutors.sameThreadExecutor Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/6d36a479 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/6d36a479 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/6d36a479 Branch: refs/heads/master Commit: 6d36a4793b31cdacaf4bbf6554e05d68bc680001 Parents: d502dde Author: Kenneth McFarland <kennethpaulmcfarl...@gmail.com> Authored: Fri Oct 20 21:05:12 2017 -0700 Committer: Kenneth McFarland <kennethpaulmcfarl...@gmail.com> Committed: Fri Oct 20 21:05:12 2017 -0700 ---------------------------------------------------------------------- .../org/apache/curator/framework/listen/ListenerContainer.java | 2 +- .../curator/framework/recipes/locks/InterProcessMutex.java | 2 +- .../org/apache/curator/framework/recipes/queue/QueueBuilder.java | 4 ++-- .../org/apache/curator/framework/recipes/shared/SharedCount.java | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/6d36a479/curator-framework/src/main/java/org/apache/curator/framework/listen/ListenerContainer.java ---------------------------------------------------------------------- diff --git a/curator-framework/src/main/java/org/apache/curator/framework/listen/ListenerContainer.java b/curator-framework/src/main/java/org/apache/curator/framework/listen/ListenerContainer.java index 549ed81..fd4497a 100644 --- a/curator-framework/src/main/java/org/apache/curator/framework/listen/ListenerContainer.java +++ b/curator-framework/src/main/java/org/apache/curator/framework/listen/ListenerContainer.java @@ -38,7 +38,7 @@ public class ListenerContainer<T> implements Listenable<T> @Override public void addListener(T listener) { - addListener(listener, MoreExecutors.sameThreadExecutor()); + addListener(listener, MoreExecutors.directExecutor()); } @Override http://git-wip-us.apache.org/repos/asf/curator/blob/6d36a479/curator-recipes/src/main/java/org/apache/curator/framework/recipes/locks/InterProcessMutex.java ---------------------------------------------------------------------- diff --git a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/locks/InterProcessMutex.java b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/locks/InterProcessMutex.java index 08b8ba1..77ef685 100644 --- a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/locks/InterProcessMutex.java +++ b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/locks/InterProcessMutex.java @@ -173,7 +173,7 @@ public class InterProcessMutex implements InterProcessLock, Revocable<InterProce @Override public void makeRevocable(RevocationListener<InterProcessMutex> listener) { - makeRevocable(listener, MoreExecutors.sameThreadExecutor()); + makeRevocable(listener, MoreExecutors.directExecutor()); } @Override http://git-wip-us.apache.org/repos/asf/curator/blob/6d36a479/curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/QueueBuilder.java ---------------------------------------------------------------------- diff --git a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/QueueBuilder.java b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/QueueBuilder.java index a571578..39ba192 100644 --- a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/QueueBuilder.java +++ b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/queue/QueueBuilder.java @@ -187,7 +187,7 @@ public class QueueBuilder<T> } /** - * Change the executor used. The default is {@link MoreExecutors#sameThreadExecutor()} + * Change the executor used. The default is {@link MoreExecutors#directExectutor()} * * @param executor new executor to use * @return this @@ -269,6 +269,6 @@ public class QueueBuilder<T> this.queuePath = PathUtils.validatePath(queuePath); factory = defaultThreadFactory; - executor = MoreExecutors.sameThreadExecutor(); + executor = MoreExecutors.directExecutor(); } } http://git-wip-us.apache.org/repos/asf/curator/blob/6d36a479/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedCount.java ---------------------------------------------------------------------- diff --git a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedCount.java b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedCount.java index 6375bdf..8ae9072 100644 --- a/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedCount.java +++ b/curator-recipes/src/main/java/org/apache/curator/framework/recipes/shared/SharedCount.java @@ -119,7 +119,7 @@ public class SharedCount implements Closeable, SharedCountReader, Listenable<Sha @Override public void addListener(SharedCountListener listener) { - addListener(listener, MoreExecutors.sameThreadExecutor()); + addListener(listener, MoreExecutors.directExecutor()); } @Override