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

Browse Source
This commit is contained in:
地平线
2015-08-13 18:01:16 +08:00
parent 110062076f
commit 0e0e1e39f5
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -10,6 +10,7 @@ import com.wentch.redkale.boot.*;
import com.wentch.redkale.convert.bson.*; import com.wentch.redkale.convert.bson.*;
import com.wentch.redkale.net.*; import com.wentch.redkale.net.*;
import com.wentch.redkale.net.sncp.*; import com.wentch.redkale.net.sncp.*;
import com.wentch.redkale.service.*;
import com.wentch.redkale.util.*; import com.wentch.redkale.util.*;
import com.wentch.redkale.watch.*; import com.wentch.redkale.watch.*;
import java.io.*; import java.io.*;
@@ -80,9 +81,9 @@ 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, sameTransports, null); SncpTestService service = Sncp.createLocalService("", 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)));
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");
conf.addValue("port", "" + port); conf.addValue("port", "" + port);
@@ -110,7 +111,8 @@ 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);
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(); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue();
conf.addValue("host", "0.0.0.0"); conf.addValue("host", "0.0.0.0");
conf.addValue("port", "" + port2); conf.addValue("port", "" + port2);