You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@curator.apache.org by ca...@apache.org on 2017/11/08 05:06:24 UTC
curator git commit: Remove calls to deprecated
MoreExecutors.sameThreadExecutor
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 <ke...@gmail.com>
Authored: Fri Oct 20 21:05:12 2017 -0700
Committer: Kenneth McFarland <ke...@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