From 2b6e1ed4f45645797b2874a7cb3be6070265be43 Mon Sep 17 00:00:00 2001 From: Christof Rabensteiner Date: Tue, 30 Apr 2019 13:44:44 +0200 Subject: Generate SoapFault instead of DRStatus/Error Message - App2MZS Server: Instead of generating a DeliveryRequestStatus/Error Message, we throw an exception. This will generate a SoapFault (including a 500 http status code), which is more appropriate. - Fix possible NPE of deliveryRequest.getMetadata().getAppDeliveryID() by moving appDeliveryID initialization into the TimeOutException catch block - pom.xml: Remove hamcrest dependency, as not needed for now. --- src/main/java/at/gv/egiz/moazs/App2MzsService.java | 29 ++++++---------------- 1 file changed, 7 insertions(+), 22 deletions(-) (limited to 'src/main') diff --git a/src/main/java/at/gv/egiz/moazs/App2MzsService.java b/src/main/java/at/gv/egiz/moazs/App2MzsService.java index 03d99fe..c89083f 100644 --- a/src/main/java/at/gv/egiz/moazs/App2MzsService.java +++ b/src/main/java/at/gv/egiz/moazs/App2MzsService.java @@ -9,12 +9,14 @@ import at.gv.e_government.reference.namespace.zustellung.mzs.app2mzs.App2MzsPort import at.gv.e_government.reference.namespace.zustellung.mzs.app2mzs_.DeliveryRequestType; import at.gv.egiz.moazs.pipeline.DeliveryPipeline; import at.gv.egiz.moazs.repository.DeliveryRepository; +import org.apache.cxf.binding.soap.SoapFault; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.jws.WebParam; +import javax.xml.XMLConstants; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; @@ -50,22 +52,22 @@ public class App2MzsService implements App2MzsPortType { targetNamespace = MZSTNS) DeliveryRequestType deliveryRequest) { - final var appDeliveryID = deliveryRequest.getMetaData().getAppDeliveryID(); - var future = supplyAsync(() -> preprocessor.preProcess(deliveryRequest)) - .thenApply((request) -> process(request)); + .thenApply(this::process); try { return future.get(TIMEOUT_FOR_ANWSER, TimeUnit.SECONDS); } catch (TimeoutException e) { future.thenAccept(appClient::sendNotification); logger.info("Answer Timed Out", e); + + var appDeliveryID = deliveryRequest.getMetaData().getAppDeliveryID(); return generatePartialSuccessResponse(appDeliveryID); } catch (Exception e ) { logger.error("Could not deliver request.", e); - var message = format("An error occured while delivering request: {0}", e.getMessage()); - return generateErrorResponse(appDeliveryID, message); + var message = format("An error occurred while processing DeliveryRequest"); + throw new RuntimeException(message, e); } } @@ -94,21 +96,4 @@ public class App2MzsService implements App2MzsPortType { .build(); } - private DeliveryRequestStatusType generateErrorResponse(String appDeliveryId, String message) { - - var info = new ErrorInfoTypeBuilder() - .withCode("500") - .withText(message) - .build(); - - var error = new ErrorBuilder() - .withAppDeliveryID(appDeliveryId) - .withErrorInfo(info) - .build(); - - return new DeliveryRequestStatusTypeBuilder() - .withError(error) - .build(); - } - } \ No newline at end of file -- cgit v1.2.3