From 24f8c388ad9d12a36b2251f455d4bd4ff3c914da Mon Sep 17 00:00:00 2001 From: OZG-Cloud Team <noreply@ozg-sh.de> 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 086f5981..6ae49090 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