From e214a73b26947065f9cbe5ef60aff7a3399f18bc Mon Sep 17 00:00:00 2001 From: "william.liangf" Date: Fri, 28 Oct 2011 08:06:20 +0000 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9multicast=E6=B3=A8=E5=86=8C?= =?UTF-8?q?=E4=B8=AD=E5=BF=83=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@113 1a56cb94-b969-4eaa-88fa-be21384802f2 --- .../registry/multicast/MulticastRegistryTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/dubbo-registry-multicast/src/test/java/com/alibaba/dubbo/registry/multicast/MulticastRegistryTest.java b/dubbo-registry-multicast/src/test/java/com/alibaba/dubbo/registry/multicast/MulticastRegistryTest.java index 75f7c53068..8172cfa132 100644 --- a/dubbo-registry-multicast/src/test/java/com/alibaba/dubbo/registry/multicast/MulticastRegistryTest.java +++ b/dubbo-registry-multicast/src/test/java/com/alibaba/dubbo/registry/multicast/MulticastRegistryTest.java @@ -40,9 +40,9 @@ public class MulticastRegistryTest { String service = "com.alibaba.dubbo.test.injvmServie"; URL registryUrl = URL.valueOf("multicast://239.255.255.255/"); - URL serviceUrl = URL.valueOf("multicast://multicast/" + service - + "?notify=false&methods=test1,test2"); - URL consumerUrl = URL.valueOf("multicast://consumer/" + service + "?notify=false&methods=test1,test2"); + URL serviceUrl = URL.valueOf("dubbo://" + NetUtils.getLocalHost() + "/" + service + + "?methods=test1,test2"); + URL consumerUrl = URL.valueOf("subscribe://" + NetUtils.getLocalHost() + "/" + service + "?arg1=1&arg2=2"); MulticastRegistry registry = new MulticastRegistry(registryUrl); /** @@ -57,7 +57,7 @@ public class MulticastRegistryTest { */ @Before public void setUp() throws Exception { - registry.register(service, serviceUrl); + registry.register(serviceUrl); } @Test(expected = IllegalArgumentException.class) @@ -95,7 +95,7 @@ public class MulticastRegistryTest { final String subscribearg = "arg1=1&arg2=2"; // verify lisener. final AtomicReference> args = new AtomicReference>(); - registry.subscribe(service, new URL("dubbo", NetUtils.getLocalHost(), 0, StringUtils.parseQueryString(subscribearg)), new NotifyListener() { + registry.subscribe(consumerUrl, new NotifyListener() { public void notify(List urls) { // FIXME assertEquals(MulticastRegistry.this.service, service); @@ -104,7 +104,7 @@ public class MulticastRegistryTest { }); assertEquals(serviceUrl.toParameterString(), StringUtils.toQueryString(args.get())); Map arg = registry.getSubscribed(service); - assertEquals(subscribearg, StringUtils.toQueryString(arg)); + assertEquals(consumerUrl.toParameterString(), StringUtils.toQueryString(arg)); }