From c556d07d3480874dddc769f7b7f19073beb77a24 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Mon, 16 Aug 2021 11:40:48 +0300 Subject: [PATCH] remote service test added --- .../it/QuarkusRedissonClientResource.java | 11 +++++++ .../quarkus/client/it/RemService.java | 27 ++++++++++++++++ .../quarkus/client/it/RemoteServiceImpl.java | 32 +++++++++++++++++++ .../src/main/resources/config.xml | 3 ++ .../src/main/resources/reflection-config.json | 6 ++++ .../it/QuarkusRedissonClientResourceTest.java | 9 ++++++ 6 files changed, 88 insertions(+) create mode 100644 redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemService.java create mode 100644 redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemoteServiceImpl.java create mode 100644 redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/config.xml create mode 100644 redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/reflection-config.json diff --git a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResource.java b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResource.java index 5454257a9..79bb1660f 100644 --- a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResource.java +++ b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResource.java @@ -55,6 +55,17 @@ public class QuarkusRedissonClientResource { return m.get("1").toString(); } + @GET + @Path("/remoteService") + public String remoteService() { + RRemoteService t = redisson.getRemoteService("test"); + + t.register(RemService.class, new RemoteServiceImpl()); + + RemService rs = t.get(RemService.class); + return rs.executeMe(); + } + @GET @Path("/pingAll") public String pingAll() { diff --git a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemService.java b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemService.java new file mode 100644 index 000000000..4ab25dec5 --- /dev/null +++ b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemService.java @@ -0,0 +1,27 @@ +/** + * Copyright (c) 2013-2021 Nikita Koksharov + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.redisson.quarkus.client.it; + +/** + * + * @author Nikita Koksharov + * + */ +public interface RemService { + + String executeMe(); + +} diff --git a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemoteServiceImpl.java b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemoteServiceImpl.java new file mode 100644 index 000000000..c7df4c2ca --- /dev/null +++ b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/java/org/redisson/quarkus/client/it/RemoteServiceImpl.java @@ -0,0 +1,32 @@ +/** + * Copyright (c) 2013-2021 Nikita Koksharov + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.redisson.quarkus.client.it; + +import org.redisson.connection.ConnectionListener; + +import java.net.InetSocketAddress; + +/** + * @author Nikita Koksharov + */ +public class RemoteServiceImpl implements RemService { + + + @Override + public String executeMe() { + return "executed"; + } +} diff --git a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/config.xml b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/config.xml new file mode 100644 index 000000000..647a252e0 --- /dev/null +++ b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/config.xml @@ -0,0 +1,3 @@ +[ + ["org.redisson.quarkus.client.it.RemService"] +] diff --git a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/reflection-config.json b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/reflection-config.json new file mode 100644 index 000000000..31802c1f0 --- /dev/null +++ b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/main/resources/reflection-config.json @@ -0,0 +1,6 @@ +[ +{ + "name":"org.redisson.quarkus.client.it.RemService", + "allDeclaredMethods":true +} +] diff --git a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/test/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResourceTest.java b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/test/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResourceTest.java index 94776344d..2873b4384 100644 --- a/redisson-quarkus/redisson-quarkus-20/integration-tests/src/test/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResourceTest.java +++ b/redisson-quarkus/redisson-quarkus-20/integration-tests/src/test/java/org/redisson/quarkus/client/it/QuarkusRedissonClientResourceTest.java @@ -11,6 +11,15 @@ import io.quarkus.test.junit.QuarkusTest; @QuarkusTest public class QuarkusRedissonClientResourceTest { + @Test + public void testRemoteService() { + given() + .when().get("/quarkus-redisson-client/remoteService") + .then() + .statusCode(200) + .body(is("executed")); + } + @Test public void testMap() { given()