You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@curator.apache.org by ra...@apache.org on 2017/07/10 15:21:39 UTC
[2/2] curator git commit: Enabled must use custom serializer now
Enabled must use custom serializer now
Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/1b2598d3
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/1b2598d3
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/1b2598d3
Branch: refs/heads/CURATOR-419
Commit: 1b2598d389b9e38182f99cd89e8c8cf1445c155a
Parents: 46e5462
Author: randgalt <ra...@apache.org>
Authored: Mon Jul 10 10:15:49 2017 -0500
Committer: randgalt <ra...@apache.org>
Committed: Mon Jul 10 10:15:49 2017 -0500
----------------------------------------------------------------------
.../apache/curator/x/discovery/details/TestServiceProvider.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/curator/blob/1b2598d3/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/details/TestServiceProvider.java
----------------------------------------------------------------------
diff --git a/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/details/TestServiceProvider.java b/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/details/TestServiceProvider.java
index fae7266..d7358fe 100644
--- a/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/details/TestServiceProvider.java
+++ b/curator-x-discovery/src/test/java/org/apache/curator/x/discovery/details/TestServiceProvider.java
@@ -85,7 +85,8 @@ public class TestServiceProvider extends BaseClassForTests
client.start();
ServiceInstance<String> instance = ServiceInstance.<String>builder().payload("thing").name("test").port(10064).enabled(false).build();
- ServiceDiscovery<String> discovery = ServiceDiscoveryBuilder.builder(String.class).basePath("/test").client(client).thisInstance(instance).build();
+ InstanceSerializer<String> serializer = new JsonInstanceSerializer<>(String.class, false);
+ ServiceDiscovery<String> discovery = ServiceDiscoveryBuilder.builder(String.class).serializer(serializer).basePath("/test").client(client).thisInstance(instance).build();
closeables.add(discovery);
discovery.start();