Repository: curator Updated Branches: refs/heads/curator-rpc 18b3fc6bc -> 01e9cb0a8
wip Project: http://git-wip-us.apache.org/repos/asf/curator/repo Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/41f254a2 Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/41f254a2 Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/41f254a2 Branch: refs/heads/curator-rpc Commit: 41f254a2542f97d3f1c81a9136a2d676cd031f58 Parents: 18b3fc6 Author: randgalt <randg...@apache.org> Authored: Tue May 27 11:26:22 2014 -0500 Committer: randgalt <randg...@apache.org> Committed: Tue May 27 11:26:22 2014 -0500 ---------------------------------------------------------------------- .../idl/projection/CuratorProjectionService.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/curator/blob/41f254a2/curator-x-rpc/src/main/java/org/apache/curator/x/rpc/idl/projection/CuratorProjectionService.java ---------------------------------------------------------------------- diff --git a/curator-x-rpc/src/main/java/org/apache/curator/x/rpc/idl/projection/CuratorProjectionService.java b/curator-x-rpc/src/main/java/org/apache/curator/x/rpc/idl/projection/CuratorProjectionService.java index aa9f286..4e8dca8 100644 --- a/curator-x-rpc/src/main/java/org/apache/curator/x/rpc/idl/projection/CuratorProjectionService.java +++ b/curator-x-rpc/src/main/java/org/apache/curator/x/rpc/idl/projection/CuratorProjectionService.java @@ -70,15 +70,6 @@ public class CuratorProjectionService return projection; } - private void addEvent(CuratorProjection projection, RpcCuratorEvent event) - { - CuratorEntry entry = rpcManager.get(projection.id); - if ( entry != null ) - { - entry.addEvent(event); - } - } - @ThriftMethod public void closeCuratorProjection(CuratorProjection projection) { @@ -128,6 +119,15 @@ public class CuratorProjectionService return String.valueOf(castBuilder(builder, PathAndBytesable.class).forPath(createSpec.path, createSpec.data)); } + private void addEvent(CuratorProjection projection, RpcCuratorEvent event) + { + CuratorEntry entry = rpcManager.get(projection.id); + if ( entry != null ) + { + entry.addEvent(event); + } + } + private org.apache.zookeeper.CreateMode getRealMode(CreateMode mode) { switch ( mode )
