1 files changed, 10 insertions, 10 deletions

diff --git a/src/main/java/at/gv/egiz/moazs/process/SafeResponseToFileSink.java b/src/main/java/at/gv/egiz/moazs/process/SafeResponseToFileSink.java
index ee32768..12a9fe3 100644
--- a/src/main/java/at/gv/egiz/moazs/process/SafeResponseToFileSink.java
+++ b/src/main/java/at/gv/egiz/moazs/process/SafeResponseToFileSink.java
@@ -1,6 +1,6 @@
 package at.gv.egiz.moazs.process;
 
-import at.gv.egiz.moazs.repository.BinaryRepository;
+import at.gv.egiz.moazs.repository.DeliveryRepository;
 import at.gv.egiz.moazs.scheme.Marshaller;
 import at.gv.egiz.moazs.scheme.MsgResponse;
 import org.apache.commons.io.FileUtils;
@@ -28,32 +28,32 @@ public class SafeResponseToFileSink implements MsgResponseSink {
     private static final SimpleDateFormat ISO_FORMATTER = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss");
 
     private final Marshaller msgMarshaller;
-    private final BinaryRepository binaryRepository;
+    private final DeliveryRepository respository;
     private final String root;
 
 
     @Autowired
-    public SafeResponseToFileSink(Marshaller msgMarshaller, BinaryRepository binaryRepository, String root) {
+    public SafeResponseToFileSink(Marshaller msgMarshaller, DeliveryRepository binaryRepository, String root) {
         this.msgMarshaller = msgMarshaller;
-        this.binaryRepository = binaryRepository;
+        this.respository = binaryRepository;
         this.root = root;
     }
 
     @Override
     public CompletableFuture<Void> handle(MsgResponse response) {
 
-        var responseId = response.getResponseID();
+        var responseID = response.getResponseID();
 
-        var responsePath = generatePath(responseId, "xml");
+        var responsePath = generatePath(responseID, "xml");
         var storeResponseToFileSystemFuture = supplyAsync(() -> msgMarshaller.marshallXml(response.getResponse()))
                 .thenApply(responseString -> responseString.getBytes(StandardCharsets.UTF_8))
                 .thenAccept(responseByteArray -> storeToFile(responsePath, responseByteArray))
-                .exceptionally((ex) -> logException(ex, responseId));
+                .exceptionally((ex) -> logException(ex, responseID));
 
-        var binaryResponsePath = generatePath(responseId, "binary.xml");
-        var storeBinaryResponseToFileSystemFuture = supplyAsync(() -> binaryRepository.get(responseId).get())
+        var binaryResponsePath = generatePath(responseID, "binary.xml");
+        var storeBinaryResponseToFileSystemFuture = supplyAsync(() -> respository.retrieveBinaryResponse(responseID).get())
                 .thenAccept(binaryResponseByteArray -> storeToFile(binaryResponsePath, binaryResponseByteArray))
-                .exceptionally((ex) -> logException(ex, responseId));
+                .exceptionally((ex) -> logException(ex, responseID));
 
         return allOf(storeResponseToFileSystemFuture, storeBinaryResponseToFileSystemFuture);