diff --git a/phase4-lib/src/main/java/com/helger/phase4/incoming/AS4RequestHandler.java b/phase4-lib/src/main/java/com/helger/phase4/incoming/AS4RequestHandler.java index 297bfdcf2..c09822af5 100644 --- a/phase4-lib/src/main/java/com/helger/phase4/incoming/AS4RequestHandler.java +++ b/phase4-lib/src/main/java/com/helger/phase4/incoming/AS4RequestHandler.java @@ -109,6 +109,7 @@ import com.helger.phase4.util.AS4ResourceHelper; import com.helger.phase4.util.AS4XMLHelper; import com.helger.phase4.util.Phase4Exception; +import com.helger.phase4.v3.ChangePhase4V3; import com.helger.photon.io.PhotonWorkerPool; import com.helger.xml.serialize.write.XMLWriter; @@ -297,6 +298,7 @@ public void applyToResponse (@Nonnull final IAS4ResponseAbstraction aHttpRespons * @author Philip Helger * @since 0.13.1 */ + @ChangePhase4V3 ("Rename") public interface ISoapProcessingFinalizedCallback { /** @@ -799,7 +801,9 @@ public final IAS4RequestHandlerErrorConsumer getErrorConsumer () /** * Set an optional error consumer that is invoked with all errors determined * during message processing. The consumed list MUST NOT be modified.
- * Note: the error consumer is ONLY called if the error list is non-empty. + * Note: the error consumer is ONLY called if the error list is non-empty.
+ * Note: the AS4 error message is sent back automatically - this is just + * informational. * * @param aErrorConsumer * The consumer to be used. May be null. @@ -859,9 +863,8 @@ private void _invokeSPIsForIncoming (@Nonnull final HttpHeaderMap aHttpHeaders, "Only one of User OR Signal Message may be present"); final boolean bIsUserMessage = aEbmsUserMessage != null; - final String sMessageID = bIsUserMessage ? aEbmsUserMessage.getMessageInfo ().getMessageId () : aEbmsSignalMessage - .getMessageInfo () - .getMessageId (); + final String sMessageID = bIsUserMessage ? aEbmsUserMessage.getMessageInfo ().getMessageId () + : aEbmsSignalMessage.getMessageInfo ().getMessageId (); // Get all processors final ICommonsList aAllProcessors = m_aProcessorSupplier.get (); @@ -1084,8 +1087,8 @@ private void _invokeSPIsForResponse (@Nonnull final IAS4IncomingMessageState aIn byte [] aResponsePayload = null; if (aResponseFactory != null) { - final HttpEntity aRealHttpEntity = aHttpEntity != null ? aHttpEntity : aResponseFactory.getHttpEntityForSending ( - aMimeType); + final HttpEntity aRealHttpEntity = aHttpEntity != null ? aHttpEntity + : aResponseFactory.getHttpEntityForSending (aMimeType); if (aRealHttpEntity.isRepeatable ()) { int nContentLength = (int) aRealHttpEntity.getContentLength (); @@ -1364,7 +1367,8 @@ private IAS4ResponseFactory _createResponseReceiptMessage (@Nonnull final IAS4In aUserMessage, aSoapDocument, _isSendNonRepudiationInformation (aEffectiveLeg), - null).setMustUnderstand (true); + null) + .setMustUnderstand (true); final ESoapVersion eResponseSoapVersion = aEffectiveLeg.getProtocol ().getSoapVersion (); if (eResponseSoapVersion != eSoapVersion) @@ -1836,8 +1840,9 @@ private IAS4ResponseFactory _handleSoapMessage (@Nonnull final HttpHeaderMap aHt new ResponseHandlerXml ()); } AS4HttpDebug.debug ( () -> "SEND-RESPONSE [async sent] received: " + - (aAsyncResponse == null ? "null" : XMLWriter.getNodeAsString (aAsyncResponse, - AS4HttpDebug.getDebugXMLWriterSettings ()))); + (aAsyncResponse == null ? "null" + : XMLWriter.getNodeAsString (aAsyncResponse, + AS4HttpDebug.getDebugXMLWriterSettings ()))); }; final CompletableFuture aFuture = PhotonWorkerPool.getInstance () @@ -2055,8 +2060,8 @@ public void handleRequest (@Nonnull @WillClose final InputStream aRequestInputSt if (aResponder != null) { // Response present -> send back - final IAS4OutgoingDumper aRealOutgoingDumper = m_aOutgoingDumper != null ? m_aOutgoingDumper : AS4DumpManager - .getOutgoingDumper (); + final IAS4OutgoingDumper aRealOutgoingDumper = m_aOutgoingDumper != null ? m_aOutgoingDumper + : AS4DumpManager.getOutgoingDumper (); aResponder.applyToResponse (aHttpResponse, aRealOutgoingDumper); } else