lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
地平线
2015-10-26 10:56:12 +08:00
parent 5697bfc0c1
commit 0132bff816
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/com/wentch/redkale/test/sncp/SncpTest.java
View File

@@ -52,7 +52,7 @@ public class SncpTest {
set.add(addr); set.add(addr);
set.add(new InetSocketAddress("127.0.0.1", port2)); set.add(new InetSocketAddress("127.0.0.1", port2));
Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set); Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set);
SncpTestService service = Sncp.createRemoteService(serviceName, SncpTestService.class, null, new LinkedHashSet<>(), transport); SncpTestService service = Sncp.createRemoteService(serviceName, null, SncpTestService.class, null, new LinkedHashSet<>(), transport);
System.out.println(service); System.out.println(service);
ResourceFactory.root().inject(service); ResourceFactory.root().inject(service);
@@ -81,7 +81,7 @@ public class SncpTest {
Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set); Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set);
List<Transport> sameTransports = new ArrayList<>(); List<Transport> sameTransports = new ArrayList<>();
sameTransports.add(transport); sameTransports.add(transport);
SncpTestService service = Sncp.createLocalService("", SncpTestService.class, addr, new LinkedHashSet<>(), sameTransports, null); SncpTestService service = Sncp.createLocalService("", null, SncpTestService.class, addr, new LinkedHashSet<>(), sameTransports, null);
ResourceFactory.root().inject(service); 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)));
System.out.println(service); System.out.println(service);
@@ -112,7 +112,7 @@ public class SncpTest {
Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set); Transport transport = new Transport("", protocol, WatchFactory.root(), 100, set);
List<Transport> sameTransports = new ArrayList<>(); List<Transport> sameTransports = new ArrayList<>();
sameTransports.add(transport); sameTransports.add(transport);
Service service = Sncp.createLocalService("", SncpTestService.class, addr, new LinkedHashSet<>(), sameTransports, null); Service service = Sncp.createLocalService("", null, SncpTestService.class, addr, new LinkedHashSet<>(), sameTransports, null);
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(); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue();
conf.addValue("host", "0.0.0.0"); conf.addValue("host", "0.0.0.0");