From 5b4678ff2602e47d749e321d93e7403c0831e2b2 Mon Sep 17 00:00:00 2001 From: OZGCloud <ozgcloud@mgm-tp.com> Date: Wed, 4 Sep 2024 10:19:26 +0200 Subject: [PATCH] OZG-6354 extract stub building; add SuppressedAnnotation --- .../eingang/router/VorgangManagerServerResolver.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/router/src/main/java/de/ozgcloud/eingang/router/VorgangManagerServerResolver.java b/router/src/main/java/de/ozgcloud/eingang/router/VorgangManagerServerResolver.java index 086f5981b..6ae490901 100644 --- a/router/src/main/java/de/ozgcloud/eingang/router/VorgangManagerServerResolver.java +++ b/router/src/main/java/de/ozgcloud/eingang/router/VorgangManagerServerResolver.java @@ -112,6 +112,11 @@ public class VorgangManagerServerResolver { var channel = createChannel(channelName); var stub = stubFactory.createStub(stubClass, channel); stub = applyStubTransformers(stub, channelName); + return buildClosableStub(stub, channel); + } + + @SuppressWarnings("unchecked") + private <T extends AbstractStub<?>> ClosableStub<T> buildClosableStub(AbstractStub<?> stub, ManagedChannel channel) { return ClosableStub.<T>builder().stub((T) stub).channel(channel).build(); } @@ -131,6 +136,11 @@ public class VorgangManagerServerResolver { var channelName = getChannelName(organisationsEinheitId); var stub = stubFactory.createStub(stubClass, createChannelByName(channelName)); stub = applyStubTransformers(stub, channelName); + return buildConsistingStub(stub); + } + + @SuppressWarnings("unchecked") + private <T extends AbstractStub<?>> ConsistingStub<T> buildConsistingStub(AbstractStub<?> stub) { return ConsistingStub.<T>builder().stub((T) stub).build(); } -- GitLab