From 0e0e1e39f596fb461bd8aa213e378f0fa0b9d2fa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=9C=B0=E5=B9=B3=E7=BA=BF?= <22250530@qq.com> Date: Thu, 13 Aug 2015 18:01:16 +0800 Subject: [PATCH] --- test/com/wentch/redkale/test/sncp/SncpTest.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/test/com/wentch/redkale/test/sncp/SncpTest.java b/test/com/wentch/redkale/test/sncp/SncpTest.java index 8eea36562..35bb55fa1 100644 --- a/test/com/wentch/redkale/test/sncp/SncpTest.java +++ b/test/com/wentch/redkale/test/sncp/SncpTest.java @@ -10,6 +10,7 @@ import com.wentch.redkale.boot.*; import com.wentch.redkale.convert.bson.*; import com.wentch.redkale.net.*; import com.wentch.redkale.net.sncp.*; +import com.wentch.redkale.service.*; import com.wentch.redkale.util.*; import com.wentch.redkale.watch.*; import java.io.*; @@ -80,9 +81,9 @@ public class SncpTest { Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set); List sameTransports = new ArrayList<>(); sameTransports.add(transport); - SncpTestService service = Sncp.createLocalService("", SncpTestService.class, addr, sameTransports, null); + SncpTestService service = Sncp.createLocalService("", SncpTestService.class, addr, new LinkedHashSet<>(), sameTransports, null); ResourceFactory.root().inject(service); - server.addService(new ServiceWrapper(SncpTestService.class, service, new ClassFilter.FilterEntry(SncpTestService.class, null))); + server.addService(new ServiceWrapper(SncpTestService.class, service, "", new ClassFilter.FilterEntry(SncpTestService.class, null))); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); conf.addValue("host", "0.0.0.0"); conf.addValue("port", "" + port); @@ -110,7 +111,8 @@ public class SncpTest { Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set); List sameTransports = new ArrayList<>(); sameTransports.add(transport); - server.addService(new ServiceWrapper(SncpTestService.class, Sncp.createLocalService("", SncpTestService.class, addr, sameTransports, null), new ClassFilter.FilterEntry(SncpTestService.class, null))); + Service service = Sncp.createLocalService("", SncpTestService.class, addr,new LinkedHashSet<>(), sameTransports, null); + server.addService(new ServiceWrapper(SncpTestService.class,service ,"", new ClassFilter.FilterEntry(SncpTestService.class, null))); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); conf.addValue("host", "0.0.0.0"); conf.addValue("port", "" + port2);