From 1d2aafe0cd6607a48d880c007881768079e49060 Mon Sep 17 00:00:00 2001 From: Christof Rabensteiner Date: Mon, 9 Dec 2019 10:25:02 +0100 Subject: Refactor & Fixes - Handle InterruptedExceptions as discussed in https://stackoverflow.com/questions/3976344/handling-interruptedexception-in-java - Remove unused imports. --- src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java') diff --git a/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java b/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java index 45a4000..cc20cc9 100644 --- a/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java +++ b/src/main/java/at/gv/egiz/moazs/backend/MsgResponseBackend.java @@ -58,7 +58,7 @@ public class MsgResponseBackend { "with AppDeliveryID=%s is not valid."; public static final String BINARY_RESPONSE_MISSING_ERROR_MSG = "Binary Response is not in repository."; public static final String RESPONSE_MISSING_ERROR_MSG = "Response with ResponseID=%s is not in repository."; - public static final String REQUEST_MISSING_ERROR_MSG = "Request with AppDeliveryID=%s is not in repository. " + + public static final String REQUEST_MISSING_ERROR_MSG = "Request with AppDeliveryID={} is not in repository. " + "Falling Back to Default Configuration."; private final DeliveryRepository repository; @@ -96,7 +96,7 @@ public class MsgResponseBackend { public CompletableFuture accept(String responseID) { log.info("Backend accepts MsgResponse with responseID={}.", responseID); return supplyAsync(() -> verifySignature(responseID), taskExecutor) - .thenCompose(msgResponse -> applySinks(msgResponse)); + .thenCompose(this::applySinks); } private MsgResponse verifySignature(String responseID) { @@ -138,7 +138,7 @@ public class MsgResponseBackend { private Supplier supplyRequestWithDefaultConfig(String appDeliveryID) { return () -> { - log.warn(format(REQUEST_MISSING_ERROR_MSG, appDeliveryID)); + log.warn(REQUEST_MISSING_ERROR_MSG, appDeliveryID); var defaultConfig = deliveryRequestConfigs.get(DEFAULT_CONFIG_KEY); validator.areSinksConfigured(defaultConfig.getMsgResponseSinks()); return deliveryRequestTypeBuilder() -- cgit v1.2.3