From 0bd5787992b8de147f1f9010b4088646f16a1650 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Wed, 15 Nov 2017 21:06:17 +0800 Subject: [PATCH] --- .../redkale/test/sncp/SncpTestIService.java | 2 ++ .../test/sncp/SncpTestServiceImpl.java | 6 ++++ .../test/sncp/_DynLocalSncpTestService.java | 28 +++++++++++++++++++ 3 files changed, 36 insertions(+) create mode 100644 test/org/redkale/test/sncp/_DynLocalSncpTestService.java diff --git a/test/org/redkale/test/sncp/SncpTestIService.java b/test/org/redkale/test/sncp/SncpTestIService.java index 3f2da2cb6..87d3f7ad0 100644 --- a/test/org/redkale/test/sncp/SncpTestIService.java +++ b/test/org/redkale/test/sncp/SncpTestIService.java @@ -17,6 +17,8 @@ public interface SncpTestIService extends Service { public String queryResult(SncpTestBean bean); + public double queryDoubleResult(String a, int b, double value); + public long queryLongResult(String a, int b, long value); public CompletableFuture queryResultAsync(SncpTestBean bean); diff --git a/test/org/redkale/test/sncp/SncpTestServiceImpl.java b/test/org/redkale/test/sncp/SncpTestServiceImpl.java index 9657596a8..1ab690c3e 100644 --- a/test/org/redkale/test/sncp/SncpTestServiceImpl.java +++ b/test/org/redkale/test/sncp/SncpTestServiceImpl.java @@ -47,6 +47,12 @@ public class SncpTestServiceImpl implements SncpTestIService { return value + 1; } + @Override + @RpcMultiRun + public double queryDoubleResult(String a, int b, double value) { + return value + 1; + } + public static class CallAttribute implements Attribute { @Override diff --git a/test/org/redkale/test/sncp/_DynLocalSncpTestService.java b/test/org/redkale/test/sncp/_DynLocalSncpTestService.java new file mode 100644 index 000000000..bbf7ef284 --- /dev/null +++ b/test/org/redkale/test/sncp/_DynLocalSncpTestService.java @@ -0,0 +1,28 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ +package org.redkale.test.sncp; + +import org.redkale.net.sncp.*; +import org.redkale.util.ResourceType; + +/** + * + * @author zhangjx + */ +@ResourceType(SncpTestIService.class) +public class _DynLocalSncpTestService extends SncpTestServiceImpl { + + private SncpClient _redkale_client; + + @SncpDyn(remote = false, index = 1) + public long _redkale_queryLongResult(boolean selfrunnable, boolean samerunnable, boolean diffrunnable, String a, int b, long value) { + long rs = super.queryLongResult(a, b, value); + if (_redkale_client == null) return rs; + if (samerunnable) _redkale_client.remoteSameGroup(1, true, false, false, a, b, value); + if (diffrunnable) _redkale_client.remoteDiffGroup(1, true, true, false, a, b, value); + return rs; + } +}