Response a SignalMessage for pull mode

[Main-Tomi]

Dear @phax,

Here is the relevant code for me to make a pull request and it can work well.
But I am currently facing difficulties in responding to customer ack.
May you guide me on how to reply to an ack (SignalMessage) to a customer?

 protected Map<String, String> executePullRequest(AS4ClientPullRequestMessage aClient, PModeLeg aleg, As4Partner as4Partner, String baseRoot, String savePath) throws ExtendedHttpResponseException, HttpHostConnectException, IOException, Exception{
        Map<String, String>parseMap = null
        String messageId = 'as4-' + MessageIdUtil.generateTransmissionId()
        aClient.setMessageID(messageId)
        IAS4OutgoingDumper dumper = new MyAS4OutgoingDumperFileBased(baseRoot)
        final Wrapper<HttpResponse> aWrappedResponse = new Wrapper<>();
        final HttpClientResponseHandler<byte[]> aResponseHdl = aHttpResponse -> {
            final HttpEntity aEntity = ResponseHandlerHttpEntity.INSTANCE.handleResponse(aHttpResponse);
            if (aEntity == null)
                return null;
            aWrappedResponse.set(aHttpResponse);
            return EntityUtils.toByteArray(aEntity);
        };
        log.info("start to pull the request from MPC[${as4Partner.mpc}], url: [${aleg.protocol.address}]")
        //send pull request
        AS4ClientSentMessage as4ClientSentMessage = aClient.sendMessageWithRetries(aleg.protocol.address, aResponseHdl, null, dumper, null)
        aClient.getAS4ResourceHelper()
        String charset = 'UTF-8'
       //handle response
        if (as4ClientSentMessage?.getBuiltMessage()?.httpEntity?.contentType){
            ContentType receivedContentType = new ContentType(as4ClientSentMessage.getBuiltMessage().httpEntity.contentType)
            charset = receivedContentType.getParameter('charset')
            log.info("Charset is:[${charset}]")
        }
        if (as4ClientSentMessage.getResponse().length > 0) {
            log.info("[pull request]PMode[${as4Partner.pModeId}],mpc[${as4Partner.mpc}], messageId[${messageId}], dumpy response to file[${baseRoot + '/incoming/' + messageId + '.as4in'}]")
            File incomingFile = FileUtil.saveFile(CommonUtils.generateFilePath(baseRoot + '/incoming', messageId + '.as4in'), as4ClientSentMessage.getResponse())
            String mdn_path = incomingFile.path + ';' + dumper.getDumpPath()

            parseMap = parseHeaderMap(as4ClientSentMessage.getResponse(), as4ClientSentMessage.messageID, charset)
            if (!as4Partner.needParseFile) {
                createFileReceivedNotification(incomingFile, as4Partner, parseMap, mdn_path, as4ClientSentMessage.messageID)
            } else {
                List<File> fileList = parseMultipartMessage(as4ClientSentMessage.getResponse(), savePath, as4ClientSentMessage.messageID, charset, parseMap)
                if (fileList.size() > 0) {
                    createFileReceivedNotification(fileList, as4Partner, parseMap, mdn_path, as4ClientSentMessage.messageID)
                } else {
                    log.warn("Can't find file in this request, messageId[${messageId}], mpc[${as4Partner.mpc}]")
                }
            }
        }else {
            log.warn("No response from partner: [${as4Partner.pModeId}]")
        }
        return parseMap
    }

I found some code from class AS4BidirectionalClientHelper:

if (aResponseEntity.hasResponse () && aResponseEntity.getResponse ().length > 0)
    {
      final IAS4IncomingMessageMetadata aMessageMetadata = AS4IncomingMessageMetadata.createForResponse (sRequestMessageID)
                                                                                     .setRemoteAddr (sURL);

      // Read response as EBMS3 User Message
      // Read it in any case to ensure signature validation etc. happens
      AS4IncomingHandler.parseUserMessage (aCryptoFactorySign,
                                           aCryptoFactoryCrypt,
                                           aPModeResolver,
                                           aIAF,
                                           aIncomingProfileSelector,
                                           aClientPullRequest.getAS4ResourceHelper (),
                                           null,
                                           aLocale,
                                           aMessageMetadata,
                                           aWrappedResponse.get (),
                                           aResponseEntity.getResponse (),
                                           aIncomingDumper,
                                           aIncomingSecurityConfiguration,
                                           aUserMsgConsumer);
    }

But I can not find SignalMessage building the from AS4IncomingHandler.parseUserMessage

Best Regards and Thanks,
Tomi Lin

[phax]

According to the ebMS 3 specification, when using a "One-Way/Pull" message, you have to respond with a UserMessage back:

In the latest version (2.8.0), there is a method AS4BidirectionalClientHelper.sendAS4PullRequestAndReceiveAS4UserMessage as well as a method AS4BidirectionalClientHelper.sendAS4PullRequestAndReceiveAS4UserOrSignalMessage which sounds like it can help you on the sending side.

On the receiving side, you need to implement the SPI IAS4ServletMessageProcessorSPI and implement the method processAS4SignalMessage. The result of the method is a AS4SignalMessageProcessorResult that includes the Ebms3UserMessage message to be returned.

[Main-Tomi]

Thank you very much for your reply. I will try and give you feedback later.

[Main-Tomi]

Dear @phax,

According to eDelivery AS4 - 2.0link

when I send a pull request to customer as4 server and pull some messages successful. The customer are expected to acknowledge positive reception of pulled user messages using ebMS3 eb:Receipt signal messages and to report errors using eb:Error signal messages.

From the AS4BidirectionalClientHelper.sendAS4PullRequestAndReceiveAS4UserOrSignalMessage, I write a function:
（builderPullRequest.sendMessage() call AS4BidirectionalClientHelper.sendAS4PullRequestAndReceiveAS4UserOrSignalMessage finally）

     void issuePullRequest() throws Exception {
        String baseRoot = propertiesConfig.basePath + '/phase4-pull-resp/phase4-as4-dumps'
        AS4Sender.BuilderPullRequest builderPullRequest = AS4Sender.builderPullRequest()
        IAS4OutgoingDumper dumper = new MyAS4OutgoingDumperFileBased(baseRoot)
        builderPullRequest.soapVersion(ESoapVersion.SOAP_12)
        builderPullRequest.mpc("http://example.phase4.org/mpc")
        builderPullRequest.outgoingDumper(dumper)
        builderPullRequest.incomingDumper(new MyAS4IncomingDumperFileBased(baseRoot))
        builderPullRequest.endpointURL("http://localhost:8080/as4")
        ESuccess eSuccess = builderPullRequest.sendMessage();
        if (eSuccess.success) {
            log.info("Pull request successful")
        }else {
            log.error("Pull request failed")
        }
//        AS4BidirectionalClientHelper.sendAS4PullRequestAndReceiveAS4UserOrSignalMessage()
    }

But I found it doesn't send a SignalMessage( ebMS3 eb:Receipt signal messages or errors using eb:Error) to customer.
I find the function AS4IncomingHandler.parseUserOrSignalMessage

public static ESuccess parseUserOrSignalMessage (@Nonnull final IAS4CryptoFactory aCryptoFactorySign,
                                                   @Nonnull final IAS4CryptoFactory aCryptoFactoryCrypt,
                                                   @Nonnull final IPModeResolver aPModeResolver,
                                                   @Nonnull final IAS4IncomingAttachmentFactory aIAF,
                                                   @Nonnull final IAS4IncomingProfileSelector aAS4ProfileSelector,
                                                   @Nonnull @WillNotClose final AS4ResourceHelper aResHelper,
                                                   @Nullable final IPMode aSendingPMode,
                                                   @Nonnull final Locale aLocale,
                                                   @Nonnull final IAS4IncomingMessageMetadata aMessageMetadata,
                                                   @Nonnull final HttpResponse aHttpResponse,
                                                   @Nonnull final byte [] aResponsePayload,
                                                   @Nullable final IAS4IncomingDumper aIncomingDumper,
                                                   @Nonnull final IAS4IncomingSecurityConfiguration aIncomingSecurityConfiguration,
                                                   @Nullable final IAS4UserMessageConsumer aUserMsgConsumer,
                                                   @Nullable final IAS4SignalMessageConsumer aSignalMsgConsumer) throws Phase4Exception
  {
    final IAS4MessageState aState = _parseMessage (aCryptoFactorySign,
                                                   aCryptoFactoryCrypt,
                                                   aPModeResolver,
                                                   aIAF,
                                                   aAS4ProfileSelector,
                                                   aResHelper,
                                                   aSendingPMode,
                                                   aLocale,
                                                   aMessageMetadata,
                                                   aHttpResponse,
                                                   aResponsePayload,
                                                   aIncomingDumper,
                                                   aIncomingSecurityConfiguration);
    if (aState == null)
    {
      // Error message was already logged
      return ESuccess.FAILURE;
    }

    final Ebms3UserMessage aUserMsg = aState.getEbmsUserMessage ();
    if (aUserMsg != null)
    {
      // Invoke consumer here, because we have the state
      if (aUserMsgConsumer != null)
        aUserMsgConsumer.handleUserMessage (aUserMsg, aMessageMetadata, aState);
    }
    else
    {
      final Ebms3SignalMessage aSignalMsg = aState.getEbmsSignalMessage ();
      if (aSignalMsg != null)
      {
        // Invoke consumer here, because we have the state
        if (aSignalMsgConsumer != null)
          aSignalMsgConsumer.handleSignalMessage (aSignalMsg, aMessageMetadata, aState);
      }
      else
        LOGGER.warn ("A Message state is present, but it contains neither a SignalMessage nor a UserMessage.");
    }
    return ESuccess.SUCCESS;
  }

Do I need to implement IAS4UserMessage Consumer and IAS4SignalMessageConsumer to consume Ebms3UserMessage and Ebms3SignalMessage in order for customers to receive this（ ebMS3 eb:Receipt signal messages or errors using eb:Error）？

[Main-Tomi]

Dear @phax,
From the document link, as a role of receiving, when send a "One-Way/Pull" message to customer, after customer return a user message, we should return a signal messages(Receipt/Error Signal).

[phax]

I think this image is confusing.
It refers to the "Flow" as an internal Holodeck construct. From an HTTP point of view, the "OneWay Pull" can look like this atm in phase4:

The complex case like this one is currently not supported because it requires a new HTTP Request for the 3rd arrow:

[Main-Tomi]

Dear @phax :

I found AS4ClientReceiptMessage to send a eb:Receipt, my code as follows:

                IAS4MessageState ias4MessageState = getIAS4MessageState(aClient, as4ClientSentMessage, aleg, aWrappedResponse, as4Partner)
                Ebms3UserMessage ebms3UserMessage = ias4MessageState.getEbmsUserMessage()
                if (ias4MessageState.getOriginalAttachments().size() > 0) {
                    if (ebms3UserMessage && as4Partner.needReturnPullACK){
                        AS4ClientReceiptMessage receiptMessage = new AS4ClientReceiptMessage(as4ResourceHelper)
                        receiptMessage.setEbms3UserMessage(ebms3UserMessage)
                        receiptMessage.setMessageID(as4ClientSentMessage.messageID+'-ACK')
                        if (aleg?.protocol?.address?.startsWith("https")){
                            log.info('start to set ssl context')
                            if (aClient?.getHttpPoster()?.getHttpClientFactory()){
                                log.info('[return pull request ack] set ssl context from pull request client')
                                receiptMessage.getHttpPoster().setHttpClientFactory(aClient.getHttpPoster().getHttpClientFactory())
                            }else{
                                log.warn("[${as4Partner.pModeId}]does not found sslContextMap in pull request client")
                            }
                        }
                        receiptMessage.setAS4CryptoFactorySign(aClient.getAS4CryptoFactorySign())
                        receiptMessage.signingParams().setAlgorithmSign(ECryptoAlgorithmSign.SIGN_ALGORITHM_DEFAULT)
                        receiptMessage.signingParams().setAlgorithmSignDigest(ECryptoAlgorithmSignDigest.SIGN_DIGEST_ALGORITHM_DEFAULT)
                        receiptMessage.signingParams().setUseSingleCertificate(as4Partner.useSingleCertificate)
                        //if need sign the receipt message
//                        receiptMessage.setReceiptShouldBeSigned(true)
                        AS4ClientSentMessage as4ClientSentMessage_1 = receiptMessage.sendMessageWithRetries(aleg.protocol.address, aResponseHdl, null, dumper, null)
                        mdn_path += ';' + dumper.getDumpPath()
                        if (as4ClientSentMessage_1.getResponse().length > 0){
                            File incomingFileACK = FileUtil.saveFile(CommonUtils.generateFilePath(baseRoot + '/incoming', as4ClientSentMessage_1.messageID + '.as4in'), as4ClientSentMessage.getResponse())
                            mdn_path += ';' + incomingFileACK.path
                        }
                    }
                    List<File> fileList = getFilesFromIAS4MessageState(ias4MessageState, baseRoot)
                    createFileReceivedNotification(fileList, as4Partner, parseMap, mdn_path, as4ClientSentMessage.messageID)
                } else {
                    log.warn("Can't find file in this request, messageId[${messageId}], mpc[${as4Partner.mpc}]")
                }

It can return a eb:Receipt like:

<?xml version="1.0" encoding="UTF-8"?>
<S12:Envelope xmlns:S12="http://www.w3.org/2003/05/soap-envelope">
	<S12:Header>
		<eb:Messaging xmlns:ds="http://www.w3.org/2000/09/xmldsig#" xmlns:eb="http://docs.oasis-open.org/ebxml-msg/ebms/v3.0/ns/core/200704/" xmlns:ebbp="http://docs.oasis-open.org/ebxml-bp/ebbp-signals-2.0" xmlns:ns5="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ns6="http://www.w3.org/2003/05/soap-envelope" xmlns:wsu="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd" xmlns:xlink="http://www.w3.org/1999/xlink" wsu:Id="phase4-msg-f7e21779-426e-4df2-966a-bf8a5a7e5e8d">
			<eb:SignalMessage>
				<eb:MessageInfo>
					<eb:Timestamp>2024-08-19T14:53:30.908+08:00</eb:Timestamp>
					<eb:MessageId>b2bi-as4-TRANS-20240819145329294-oQsE-ACK</eb:MessageId>
					<eb:RefToMessageId>0bc86f4a-fc9e-46d9-98ae-b00ea66abfa4@h-3fd1709704538b52.3fe73680524cb854</eb:RefToMessageId>
				</eb:MessageInfo>
				<eb:Receipt>
					<S12:Envelope>
						<S12:Header>
							<eb:Messaging wsu:Id="phase4-msg-1918e0c9-9cb1-485e-85ac-2856da6fb0b8">
								<eb:UserMessage mpc="http://example.b2bi-isaas.org/mpc">
									<eb:MessageInfo>
										<eb:Timestamp>2024-08-19T06:19:24.74Z</eb:Timestamp>
										<eb:MessageId>0bc86f4a-fc9e-46d9-98ae-b00ea66abfa4@h-3fd1709704538b52.3fe73680524cb854</eb:MessageId>
									</eb:MessageInfo>
									<eb:PartyInfo>
										<eb:From>
											<eb:PartyId type="urn:fdc:peppol.eu:2017:identifiers:ap">b2bi-test</eb:PartyId>
											<eb:Role>Receiver</eb:Role>
										</eb:From>
										<eb:To>
											<eb:PartyId type="urn:fdc:peppol.eu:2017:identifiers:ap">user2</eb:PartyId>
											<eb:Role>Sender</eb:Role>
										</eb:To>
									</eb:PartyInfo>
									<eb:CollaborationInfo>
										<eb:AgreementRef>urn:fdc:peppol.eu:2017:b2bi-isaas:tia:ap_provider</eb:AgreementRef>
										<eb:Service type="type-b2bi-test">Examples-b2bi-test</eb:Service>
										<eb:Action>StoreMessage-b2bi-test</eb:Action>
										<eb:ConversationId>org:holodeckb2b:example:conversation</eb:ConversationId>
									</eb:CollaborationInfo>
									<eb:PayloadInfo>
										<eb:PartInfo href="cid:0bc86f4a-fc9e-46d9-98ae-b00ea66abfa4-2014066072@h-3fd1709704538b52.3fe73680524cb854">
											<eb:PartProperties>
												<eb:Property name="CompressionType">application/gzip</eb:Property>
												<eb:Property name="MimeType">text/plain</eb:Property>
											</eb:PartProperties>
										</eb:PartInfo>
										<eb:PartInfo href="cid:0bc86f4a-fc9e-46d9-98ae-b00ea66abfa4-2042108672@h-3fd1709704538b52.3fe73680524cb854">
											<eb:PartProperties>
												<eb:Property name="CompressionType">application/gzip</eb:Property>
												<eb:Property name="MimeType">text/plain</eb:Property>
											</eb:PartProperties>
										</eb:PartInfo>
										<eb:PartInfo href="cid:0bc86f4a-fc9e-46d9-98ae-b00ea66abfa4-2020223318@h-3fd1709704538b52.3fe73680524cb854">
											<eb:PartProperties>
												<eb:Property name="CompressionType">application/gzip</eb:Property>
												<eb:Property name="MimeType">text/plain</eb:Property>
											</eb:PartProperties>
										</eb:PartInfo>
									</eb:PayloadInfo>
								</eb:UserMessage>
							</eb:Messaging>
						</S12:Header>
						<S12:Body />
					</S12:Envelope>
				</eb:Receipt>
			</eb:SignalMessage>
		</eb:Messaging>
	</S12:Header>
	<S12:Body />
</S12:Envelope>

I don't know if my usage is correct. And what should I do if I want to reply with a eb:Error?

[Main-Tomi]

Yes, I test it with holodesk b2b, and it can work well.

[Main-Tomi]

Dear @phax,
I found AS4ClientReceiptMessage and AS4ClientErrorMessage can do it(eb:Receipt and eb:Error) well.
My code as follows:

    private void returnErrorMessage(AS4ClientPullRequestMessage aClient, PModeLeg aleg, As4Partner as4Partner, String mdn_path, String baseRoot,
                                    Ebms3UserMessage ebms3UserMessage,HttpClientResponseHandler<byte[]> aResponseHdl,
                                      MyAS4OutgoingDumperFileBased dumper, String orgMessageId) throws Exception{
        AS4ClientErrorMessage errorMessage = new AS4ClientErrorMessage(as4ResourceHelper)
        errorMessage.addErrorMessage(EEbmsError.EBMS_OTHER, Locale.US )
        errorMessage.setRefToMessageID(ebms3UserMessage.getMessageInfo().messageId)
//        errorMessage.buildMessage(orgMessageId+'-ERROR-ACK', null)
        if (aClient.signingParams()){
            errorMessage.setAS4CryptoFactorySign(aClient.getAS4CryptoFactorySign())
            errorMessage.signingParams().setAlgorithmSign(ECryptoAlgorithmSign.SIGN_ALGORITHM_DEFAULT)
            errorMessage.signingParams().setAlgorithmSignDigest(ECryptoAlgorithmSignDigest.SIGN_DIGEST_ALGORITHM_DEFAULT)
            errorMessage.signingParams().setUseSingleCertificate(as4Partner.useSingleCertificate)
            errorMessage.setErrorShouldBeSigned(true)
        }
        if (aleg?.protocol?.address?.startsWith("https")){
            log.info('start to set ssl context')
            if (aClient?.getHttpPoster()?.getHttpClientFactory()){
                log.info('[return pull request ack] set ssl context from pull request client')
                errorMessage.getHttpPoster().setHttpClientFactory(aClient.getHttpPoster().getHttpClientFactory())
            }else{
                log.warn("[${as4Partner.pModeId}]does not found sslContextMap in pull request client")
            }
        }
        AS4ClientSentMessage error = errorMessage.sendMessageWithRetries(aleg.protocol.address, aResponseHdl, null, dumper, null)
        mdn_path += ';' + dumper.getDumpPath()
        if (error.getResponse().length > 0){
            File incomingFileACK = FileUtil.saveFile(CommonUtils.generateFilePath(baseRoot + '/incoming', error.messageID + '.as4in'), error.getResponse())
            mdn_path += ';' + incomingFileACK.path
        }
    }

[phax]

Looks generally okay, however I would replace

 errorMessage.signingParams ().setAlgorithmSign (ECryptoAlgorithmSign.SIGN_ALGORITHM_DEFAULT);
      errorMessage.signingParams ().setAlgorithmSignDigest (ECryptoAlgorithmSignDigest.SIGN_DIGEST_ALGORITHM_DEFAULT);
      errorMessage.signingParams ().setUseSingleCertificate (as4Partner.useSingleCertificate);

with

aClient.signingParams().cloneTo (errorMessage.signingParams ());

to copy all parameters from the source message to the error message

[phax]

Also some improved error text would be good.

errorMessage.addErrorMessage(EEbmsError.EBMS_OTHER, Locale.US )

sends only a standard text.
Try

errorMessage.errorMessages ().add (EEbmsError.EBMS_OTHER.errorBuilder (Locale.US)
                                                           .refToMessageInError (ebms3UserMessage.getMessageInfo().messageId)
                                                           .errorDetail ("This is why it failed")
                                                           .build ());

[Main-Tomi]

Yes, it looks very good. Thank you for your reply and I will try it at once.

[phax]

I tried to something similar, but with the latest (unreleased) 3.0 code and came to a code like in this commit (9e6d970) but I have no way of testing it. Any feedback would be appreciated

[Main-Tomi]

Hi, phax,

I pull the latest code for master branch, but I can't build successful and I found the package com.helger.phase4.ebms3header does not exist in project. So I can not use your code to test.


And My code worked well in this requirement.I hope this is helpful to you.

protected Map<String, String> executePullRequest(AS4ClientPullRequestMessage aClient, PModeLeg aleg, As4Partner as4Partner, String baseRoot, String savePath) throws ExtendedHttpResponseException, HttpHostConnectException, IOException, Exception {
        Map<String, String> parseMap = null
        String messageId = 'phase4-' + MessageIdUtil.generateTransmissionId()
        aClient.setMessageID(messageId)
        MyAS4OutgoingDumperFileBased dumper = new MyAS4OutgoingDumperFileBased(baseRoot)
        final Wrapper<HttpResponse> aWrappedResponse = new Wrapper<>();
        final HttpClientResponseHandler<byte[]> aResponseHdl = aHttpResponse -> {
            final HttpEntity aEntity = ResponseHandlerHttpEntity.INSTANCE.handleResponse(aHttpResponse);
            if (aEntity == null)
                return null;
            aWrappedResponse.set(aHttpResponse);
            return EntityUtils.toByteArray(aEntity);
        };
        log.info("start to pull the request from MPC[${as4Partner.mpc}], url: [${aleg.protocol.address}]")
        AS4ClientSentMessage as4ClientSentMessage = aClient.sendMessageWithRetries(aleg.protocol.address, aResponseHdl, null, dumper, null)
        String charset = 'UTF-8'
        if (as4ClientSentMessage?.getBuiltMessage()?.httpEntity?.contentType) {
            ContentType receivedContentType = new ContentType(as4ClientSentMessage.getBuiltMessage().httpEntity.contentType)
            charset = receivedContentType.getParameter('charset')
            log.info("Charset is:[${charset}]")
        }
        if (as4ClientSentMessage.getResponse().length > 0) {
            log.info("[pull request]PMode[${as4Partner.pModeId}],mpc[${as4Partner.mpc}], messageId[${messageId}], dumpy response to file[${baseRoot + '/incoming/' + messageId + '.as4in'}]")
            File incomingFile = FileUtil.saveFile(CommonUtils.generateFilePath(baseRoot + '/incoming', messageId + '.as4in'), as4ClientSentMessage.getResponse())
            String mdn_path = incomingFile.path + ';' + dumper.getDumpPath()
            parseMap = parseHeaderMap(as4ClientSentMessage.getResponse(), as4ClientSentMessage.messageID, charset)

            IAS4MessageState ias4MessageState = getIAS4MessageState(aClient, as4ClientSentMessage, aleg, aWrappedResponse, as4Partner)
            Ebms3UserMessage ebms3UserMessage = ias4MessageState.getEbmsUserMessage()
            try{
                if (ias4MessageState.getOriginalAttachments().size() > 0) {
                    if (ebms3UserMessage && as4Partner.needReturnPullACK) {
                        MyAS4ClientReceiptMessage receiptMessage = new MyAS4ClientReceiptMessage(as4ResourceHelper)
                        receiptMessage.setEbms3UserMessage(ebms3UserMessage)
                        receiptMessage.setMessageID(as4ClientSentMessage.messageID + '-ACK')
                        if (aClient?.getHttpPoster()?.getHttpClientFactory()) {
                            log.info('[return pull request ack] set ssl context from pull request client')
                            receiptMessage.getHttpPoster().setHttpClientFactory(aClient.getHttpPoster().getHttpClientFactory())
                        }
                        if (aClient.getAS4CryptoFactorySign()) {
                            receiptMessage.setAS4CryptoFactorySign(aClient.getAS4CryptoFactorySign())
                            aClient.signingParams().cloneTo(receiptMessage.signingParams())
                            receiptMessage.setReceiptShouldBeSigned(true)
                        }
                        AS4ClientSentMessage as4ClientSentMessage_1 = receiptMessage.sendMessageWithRetries(aleg.protocol.address, aResponseHdl, null, dumper, null)
                        mdn_path += ';' + dumper.getDumpPath()
                        if (as4ClientSentMessage_1.getResponse().length > 0) {
                            File incomingFileACK = FileUtil.saveFile(CommonUtils.generateFilePath(baseRoot + '/incoming', as4ClientSentMessage_1.messageID + '.as4in'), as4ClientSentMessage.getResponse())
                            mdn_path += ';' + incomingFileACK.path
                        }
                    }
                    List<File> fileList = getFilesFromIAS4MessageState(ias4MessageState, baseRoot)
                    createFileReceivedNotification(fileList, as4Partner, parseMap, mdn_path, as4ClientSentMessage.messageID)
                } else {
                    log.warn("Can't find file in this request, messageId[${messageId}], mpc[${as4Partner.mpc}]")
                }
            }catch (Exception e){
                returnErrorMessage(aClient, aleg, as4Partner, mdn_path, baseRoot, ebms3UserMessage, aResponseHdl, dumper)
                e.printStackTrace()
            }
        } else {
            log.warn("No response from partner: [${as4Partner.pModeId}]")
        }
        return parseMap
    }

    private String returnErrorMessage(AS4ClientPullRequestMessage aClient, PModeLeg aleg, As4Partner as4Partner, String mdn_path, String baseRoot,
                                    Ebms3UserMessage ebms3UserMessage,HttpClientResponseHandler<byte[]> aResponseHdl,
                                      MyAS4OutgoingDumperFileBased dumper) throws Exception{
        AS4ClientErrorMessage errorMessage = new AS4ClientErrorMessage(as4ResourceHelper)
        errorMessage.errorMessages().add(EEbmsError.EBMS_OTHER.errorBuilder(Locale.US)
                .refToMessageInError(ebms3UserMessage.getMessageInfo().messageId)
                .errorDetail("This is why it failed")
                .build() )
       errorMessage.setRefToMessageID(ebms3UserMessage.getMessageInfo().messageId)
        if (aClient.signingParams()){
            errorMessage.setAS4CryptoFactorySign(aClient.getAS4CryptoFactorySign())
            aClient.signingParams().cloneTo(errorMessage.signingParams())
        }
        if (aleg?.protocol?.address?.startsWith("https")){
            log.info('start to set ssl context')
            if (aClient?.getHttpPoster()?.getHttpClientFactory()){
                log.info('[return pull request ack] set ssl context from pull request client')
                errorMessage.getHttpPoster().setHttpClientFactory(aClient.getHttpPoster().getHttpClientFactory())
            }else{
                log.warn("[${as4Partner.pModeId}]does not found sslContextMap in pull request client")
            }
        }
        AS4ClientSentMessage error = errorMessage.sendMessageWithRetries(aleg.protocol.address, aResponseHdl, null, dumper, null)
        mdn_path += ';' + dumper.getDumpPath()
        if (error.getResponse().length > 0){
            File incomingFileACK = FileUtil.saveFile(CommonUtils.generateFilePath(baseRoot + '/incoming', error.messageID + '.as4in'), error.getResponse())
            mdn_path += ';' + incomingFileACK.path
        }
        return mdn_path
    }

Customer message history for eb:Receipt

Customer message history for eb:Error