From 5ee2fdd40732aa8eca29e89b14fa5238385868e8 Mon Sep 17 00:00:00 2001 From: Christof Rabensteiner Date: Tue, 16 Apr 2019 11:49:56 +0200 Subject: Store incoming delivery request on redis server - Connect to Redis server and implement RedisRepository - Add redis dependencies (spring-boot-starter, jedis, apache commons io). Latter dependencies are apparently needed and not included in the sprint-boot-starter; See https://github.com/spring-projects/spring-boot/issues/5718 and https://www.concretepage.com/questions/599 - Connect DeliveryRequestHandler to RedisRepository - Rewrote Marshalling: replace JaxbContext with spring-oxm JaxbMarshaller - Catch and log all exceptions in App2MZSService; Former: certain exceptions would go unnoticed, e.g. ConnectionRefused --- .../java/at/gv/egiz/moazs/DeliveryRequestHandler.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) (limited to 'src/main/java/at/gv/egiz/moazs/DeliveryRequestHandler.java') diff --git a/src/main/java/at/gv/egiz/moazs/DeliveryRequestHandler.java b/src/main/java/at/gv/egiz/moazs/DeliveryRequestHandler.java index c5ecdb5..16235cf 100644 --- a/src/main/java/at/gv/egiz/moazs/DeliveryRequestHandler.java +++ b/src/main/java/at/gv/egiz/moazs/DeliveryRequestHandler.java @@ -2,23 +2,36 @@ package at.gv.egiz.moazs; import at.gv.e_government.reference.namespace.zustellung.mzs.app2mzs_.DeliveryRequestType; import at.gv.e_government.reference.namespace.zustellung.mzs.app2mzs_.DeliveryResponseType; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import javax.xml.bind.JAXBElement; import java.util.function.Function; @Component public class DeliveryRequestHandler implements Function { + private static final Logger logger = LoggerFactory.getLogger(DeliveryRequestHandler.class); + + @Autowired + private RedisRepository repository; /** * Handles the Delivery Request */ @Override - public DeliveryResponseType apply(DeliveryRequestType deliveryRequestType) { + public DeliveryResponseType apply(DeliveryRequestType deliveryRequest) { + + var deliveryId = deliveryRequest.getMetaData().getAppDeliveryID(); + logger.info(String.format("Received Request with AppDeliveryID = %s", deliveryId)); //check if DR is complete - // + + //store delivery request + repository.add(deliveryRequest); return null; } -- cgit v1.2.3