From 8aba1b4f18f5fbfebdf239b4b4945b628e439905 Mon Sep 17 00:00:00 2001
From: Christof Rabensteiner <christof.rabensteiner@iaik.tugraz.at>
Date: Tue, 9 Jul 2019 14:11:47 +0200
Subject: Refactor Needles Interfaces and Rename "process" to "backend"

Reason:
- Interfaces with a single method can be replaced with
  interfaces from java.util.function.
- Less interfaces = less code = less maintenance!
- Spring can inject beans by name so we name dependencies correctly
  to prevent ambiguity.

Others:
- Rename process to backend since backend gives a better description
  of its components.
---
 src/main/java/at/gv/egiz/moazs/service/MzsService.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

(limited to 'src/main/java/at/gv/egiz/moazs/service/MzsService.java')

diff --git a/src/main/java/at/gv/egiz/moazs/service/MzsService.java b/src/main/java/at/gv/egiz/moazs/service/MzsService.java
index 2755a37..c8c0878 100644
--- a/src/main/java/at/gv/egiz/moazs/service/MzsService.java
+++ b/src/main/java/at/gv/egiz/moazs/service/MzsService.java
@@ -1,7 +1,6 @@
 package at.gv.egiz.moazs.service;
 
 import at.gv.egiz.moazs.preprocess.DeliveryRequestAugmenter;
-import at.gv.egiz.moazs.process.DeliveryPipeline;
 import at.gv.egiz.moazs.repository.DeliveryRepository;
 import at.gv.egiz.moazs.scheme.Msg2MzsConverter;
 import at.gv.egiz.moazs.client.MzsClient;
@@ -19,6 +18,7 @@ import org.springframework.stereotype.Service;
 import javax.jws.WebParam;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
+import java.util.function.Consumer;
 
 import static at.gv.egiz.moazs.MoaZSException.moaZSException;
 import static at.gv.egiz.moazs.MoaZSException.moaZSExceptionBuilder;
@@ -36,16 +36,16 @@ public class MzsService implements App2MzsPortType {
     private static final int TIMEOUT_FOR_ANWSER = 10;
 
     private final DeliveryRepository repository;
-    private final DeliveryPipeline pipeline;
+    private final Consumer<String> backend;
     private final MzsClient appClient;
     private final DeliveryRequestAugmenter augmenter;
     private final Msg2MzsConverter converter;
 
     @Autowired
-    public MzsService(DeliveryRepository repository, DeliveryPipeline pipeline, MzsClient appClient,
+    public MzsService(DeliveryRepository repository, Consumer<String> deliveryRequestBackend, MzsClient appClient,
                       DeliveryRequestAugmenter augmenter, Msg2MzsConverter converter) {
         this.repository = repository;
-        this.pipeline = pipeline;
+        this.backend = deliveryRequestBackend;
         this.appClient = appClient;
         this.augmenter = augmenter;
         this.converter = converter;
@@ -87,7 +87,7 @@ public class MzsService implements App2MzsPortType {
         logger.info("Receive request with appDeliveryID = {}.", appDeliveryID);
 
         repository.store(deliveryRequest);
-        pipeline.processRequest(appDeliveryID);
+        backend.accept(appDeliveryID);
 
         var statusId = RequestStatusResponse.getResponseID(appDeliveryID);
         var response = repository.retrieveResponse(statusId)
-- 
cgit v1.2.3