aboutsummaryrefslogtreecommitdiff
path: root/src/main/java
diff options
context:
space:
mode:
authorChristof Rabensteiner <christof.rabensteiner@iaik.tugraz.at>2019-04-30 13:44:44 +0200
committerChristof Rabensteiner <christof.rabensteiner@iaik.tugraz.at>2019-04-30 13:44:44 +0200
commit2b6e1ed4f45645797b2874a7cb3be6070265be43 (patch)
treefb4b287147c5e9ff452b8f02b41bbd3870617ecc /src/main/java
parent4592b1fac0ebef1d0ee2ff650ea0c46514539dfc (diff)
downloadmoa-zs-2b6e1ed4f45645797b2874a7cb3be6070265be43.tar.gz
moa-zs-2b6e1ed4f45645797b2874a7cb3be6070265be43.tar.bz2
moa-zs-2b6e1ed4f45645797b2874a7cb3be6070265be43.zip
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.
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/at/gv/egiz/moazs/App2MzsService.java29
1 files changed, 7 insertions, 22 deletions
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