diff --git a/test/org/redkale/test/sncp/SncpTest.java b/test/org/redkale/test/sncp/SncpTest.java index b029a2bef..754b7fa0e 100644 --- a/test/org/redkale/test/sncp/SncpTest.java +++ b/test/org/redkale/test/sncp/SncpTest.java @@ -5,26 +5,20 @@ */ package org.redkale.test.sncp; -import org.redkale.net.sncp.Sncp; -import org.redkale.convert.bson.BsonFactory; -import org.redkale.net.Transport; -import org.redkale.service.Service; -import org.redkale.net.sncp.SncpServer; -import org.redkale.convert.bson.BsonConvert; -import org.redkale.util.Utility; -import org.redkale.net.sncp.ServiceWrapper; -import org.redkale.util.AnyValue; -import org.redkale.watch.WatchFactory; -import org.redkale.util.ResourceFactory; import java.io.*; -import java.net.*; -import java.nio.*; -import java.nio.channels.*; +import java.net.InetSocketAddress; +import java.nio.ByteBuffer; +import java.nio.channels.AsynchronousChannelGroup; import java.util.*; import java.util.concurrent.*; import java.util.concurrent.atomic.*; -import java.util.logging.*; +import java.util.logging.LogManager; +import org.redkale.convert.bson.*; +import org.redkale.net.Transport; +import org.redkale.net.sncp.*; +import org.redkale.service.Service; import org.redkale.util.*; +import org.redkale.watch.WatchFactory; /** * @@ -160,7 +154,7 @@ public class SncpTest { final Transport transport = new Transport("", WatchFactory.root(), newBufferPool(), newChannelGroup(), null, set); SncpTestService service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, addr, transport, null); ResourceFactory.root().inject(service); - server.addService(new ServiceWrapper(SncpTestService.class, service, "", "", new HashSet<>(), null)); + server.addService(new ServiceWrapper(service, "", "", new HashSet<>(), null)); System.out.println(service); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); conf.addValue("host", "0.0.0.0"); @@ -193,7 +187,7 @@ public class SncpTest { //String name, WatchFactory, ObjectPool, AsynchronousChannelGroup, InetSocketAddress clientAddress, Collection final Transport transport = new Transport("", WatchFactory.root(), newBufferPool(), newChannelGroup(), null, set); Service service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, addr, transport, null); - server.addService(new ServiceWrapper(SncpTestService.class, service, "", "", new HashSet<>(), null)); + server.addService(new ServiceWrapper(service, "", "", new HashSet<>(), null)); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); conf.addValue("host", "0.0.0.0"); conf.addValue("port", "" + port2); diff --git a/test/org/redkale/test/sncp/SncpTestIService.java b/test/org/redkale/test/sncp/SncpTestIService.java index 0d9c554e1..fc7fd52b3 100644 --- a/test/org/redkale/test/sncp/SncpTestIService.java +++ b/test/org/redkale/test/sncp/SncpTestIService.java @@ -6,7 +6,7 @@ package org.redkale.test.sncp; import org.redkale.service.*; -import org.redkale.source.*; +import org.redkale.source.DataCallArrayAttribute; /** * @@ -14,6 +14,8 @@ import org.redkale.source.*; */ public interface SncpTestIService extends Service { + public String queryResult(SncpTestBean bean); + public void insert(@DynCall(DataCallArrayAttribute.class) SncpTestBean... beans); public String updateBean(@DynCall(SncpTestService.CallAttribute.class) SncpTestBean bean); diff --git a/test/org/redkale/test/sncp/SncpTestService.java b/test/org/redkale/test/sncp/SncpTestService.java index 260118d92..37b3b83a6 100644 --- a/test/org/redkale/test/sncp/SncpTestService.java +++ b/test/org/redkale/test/sncp/SncpTestService.java @@ -5,11 +5,10 @@ */ package org.redkale.test.sncp; -import java.lang.reflect.*; -import java.net.*; +import java.lang.reflect.Method; +import java.net.InetSocketAddress; import org.redkale.net.sncp.*; import org.redkale.service.*; -import org.redkale.util.Attribute; import org.redkale.source.DataCallArrayAttribute; import org.redkale.util.*; @@ -17,7 +16,7 @@ import org.redkale.util.*; * * @author zhangjx */ -@ResourceType({SncpTestIService.class}) +@ResourceType({SncpTestIService.class, SncpTestService.class}) public class SncpTestService implements SncpTestIService { public static class CallAttribute implements Attribute {