From d39b3856ca31b8240c8f6f32c769224e0783229e Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Wed, 19 Apr 2017 18:52:20 +0800 Subject: [PATCH] --- test/org/redkale/test/sncp/SncpTest.java | 6 +++--- test/org/redkale/test/sncp/SncpTestIService.java | 2 +- .../{SncpTestService.java => SncpTestServiceImpl.java} | 8 ++++---- 3 files changed, 8 insertions(+), 8 deletions(-) rename test/org/redkale/test/sncp/{SncpTestService.java => SncpTestServiceImpl.java} (90%) diff --git a/test/org/redkale/test/sncp/SncpTest.java b/test/org/redkale/test/sncp/SncpTest.java index bab9e6382..5670d6c10 100644 --- a/test/org/redkale/test/sncp/SncpTest.java +++ b/test/org/redkale/test/sncp/SncpTest.java @@ -82,7 +82,7 @@ public class SncpTest { if (port2 > 0) set.add(new InetSocketAddress(myhost, port2)); //String name, WatchFactory, ObjectPool, AsynchronousChannelGroup, InetSocketAddress clientAddress, Collection final Transport transport = new Transport("", WatchFactory.root(), "", newBufferPool(), newChannelGroup(), null, set); - final SncpTestService service = Sncp.createRemoteService(serviceName, null, SncpTestService.class, null, transport); + final SncpTestIService service = Sncp.createRemoteService(serviceName, null, SncpTestIService.class, null, transport); ResourceFactory.root().inject(service); // SncpTestBean bean = new SncpTestBean(); @@ -152,7 +152,7 @@ public class SncpTest { if (port2 > 0) set.add(new InetSocketAddress(myhost, port2)); //String name, WatchFactory, ObjectPool, AsynchronousChannelGroup, InetSocketAddress clientAddress, Collection final Transport transport = new Transport("", WatchFactory.root(), "", newBufferPool(), newChannelGroup(), null, set); - SncpTestService service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, addr, transport, null); + SncpTestIService service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestServiceImpl.class, addr, transport, null); ResourceFactory.root().inject(service); server.addSncpServlet(new ServiceWrapper(service, "", "", new HashSet<>(), null)); System.out.println(service); @@ -186,7 +186,7 @@ public class SncpTest { set.add(new InetSocketAddress(myhost, port)); //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); + Service service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestServiceImpl.class, addr, transport, null); server.addSncpServlet(new ServiceWrapper(service, "", "", new HashSet<>(), null)); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); conf.addValue("host", "0.0.0.0"); diff --git a/test/org/redkale/test/sncp/SncpTestIService.java b/test/org/redkale/test/sncp/SncpTestIService.java index 4d5e12585..1deec776d 100644 --- a/test/org/redkale/test/sncp/SncpTestIService.java +++ b/test/org/redkale/test/sncp/SncpTestIService.java @@ -18,5 +18,5 @@ public interface SncpTestIService extends Service { public void insert(@RpcCall(DataCallArrayAttribute.class) SncpTestBean... beans); - public String updateBean(@RpcCall(SncpTestService.CallAttribute.class) SncpTestBean bean); + public String updateBean(@RpcCall(SncpTestServiceImpl.CallAttribute.class) SncpTestBean bean); } diff --git a/test/org/redkale/test/sncp/SncpTestService.java b/test/org/redkale/test/sncp/SncpTestServiceImpl.java similarity index 90% rename from test/org/redkale/test/sncp/SncpTestService.java rename to test/org/redkale/test/sncp/SncpTestServiceImpl.java index 9713b1c73..825e7b170 100644 --- a/test/org/redkale/test/sncp/SncpTestService.java +++ b/test/org/redkale/test/sncp/SncpTestServiceImpl.java @@ -16,8 +16,8 @@ import org.redkale.util.*; * * @author zhangjx */ -@ResourceType({SncpTestIService.class, SncpTestService.class}) -public class SncpTestService implements SncpTestIService { +@ResourceType({SncpTestIService.class}) +public class SncpTestServiceImpl implements SncpTestIService { public static class CallAttribute implements Attribute { @@ -74,7 +74,7 @@ public class SncpTestService implements SncpTestIService { } public static void main(String[] args) throws Exception { - Service service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, new InetSocketAddress("127.0.0.1", 7070), null, null); + Service service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestServiceImpl.class, new InetSocketAddress("127.0.0.1", 7070), null, null); for (Method method : service.getClass().getDeclaredMethods()) { System.out.println(method); } @@ -83,7 +83,7 @@ public class SncpTestService implements SncpTestIService { System.out.println(method); } System.out.println("-----------------------------------"); - service = Sncp.createRemoteService("", null, SncpTestService.class, new InetSocketAddress("127.0.0.1", 7070), null); + service = Sncp.createRemoteService("", null, SncpTestServiceImpl.class, new InetSocketAddress("127.0.0.1", 7070), null); for (Method method : service.getClass().getDeclaredMethods()) { System.out.println(method); }