Refactor & Fixes

- Handle InterruptedExceptions as discussed in
  https://stackoverflow.com/questions/3976344/handling-interruptedexception-in-java
- Remove unused imports.

1 files changed, 3 insertions, 3 deletions

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<Void> 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<DeliveryRequestType> 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()