diff --git a/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4IncomingHandler.java b/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4IncomingHandler.java index 9d712fe60..13e2a5e60 100644 --- a/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4IncomingHandler.java +++ b/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4IncomingHandler.java @@ -172,8 +172,8 @@ public static void parseAS4Message (@Nonnull final IAS4IncomingAttachmentFactory final IMimeType aPlainContentType = aContentType.getCopyWithoutParameters (); // Fallback to global dumper if none is provided - final IAS4IncomingDumper aRealIncomingDumper = aIncomingDumper != null ? aIncomingDumper - : AS4DumpManager.getIncomingDumper (); + final IAS4IncomingDumper aRealIncomingDumper = aIncomingDumper != null ? aIncomingDumper : AS4DumpManager + .getIncomingDumper (); Document aSoapDocument = null; ESoapVersion eSoapVersion = null; @@ -468,8 +468,7 @@ private static void _processSoapHeaderElements (@Nonnull final SOAPHeaderElement aHeader.getNode (), aIncomingAttachments, aState, - aErrorList) - .isSuccess ()) + aErrorList).isSuccess ()) { // Mark header as processed (for mustUnderstand check) aHeader.setProcessed (true); @@ -814,8 +813,6 @@ public static IAS4MessageState processEbmsMessage (@Nonnull @WillNotClose final final boolean bIsPingMessage = AS4Helper.isPingMessage (aPMode); aState.setPingMessage (bIsPingMessage); - if (bIsPingMessage && (aProfile == null || !aProfile.isInvokeSPIForPingMessage())) - LOGGER.info ("Received an AS4 Ping message - meaning it will NOT be handled by the custom handlers."); } return aState; diff --git a/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4RequestHandler.java b/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4RequestHandler.java index 6b04e8996..52617f405 100644 --- a/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4RequestHandler.java +++ b/phase4-lib/src/main/java/com/helger/phase4/servlet/AS4RequestHandler.java @@ -666,8 +666,9 @@ 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 (); @@ -876,8 +877,8 @@ private void _invokeSPIsForResponse (@Nonnull final IAS4MessageState aState, 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 (); @@ -1395,6 +1396,8 @@ private IAS4ResponseFactory _handleSoapMessage (@Nonnull final HttpHeaderMap aHt if (aState.isPingMessage ()) bCanInvokeSPIs = aAS4Profile.isInvokeSPIForPingMessage (); } + if (aState.isPingMessage () && !bCanInvokeSPIs) + LOGGER.info ("Received an AS4 Ping message - meaning it will NOT be handled by the custom handlers."); if (bCanInvokeSPIs) { @@ -1551,9 +1554,8 @@ 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 () @@ -1778,8 +1780,8 @@ public void handleRequest (@Nonnull @WillClose final InputStream aServletRequest 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