1

WCF-Custom アダプター (wsHTTP バインディング) を介してメッセージをプッシュする際に問題が発生しています。カスタム エンドポイント動作拡張 MessageInspector を使用して、SOAP エンベロープから MessageID、ReplyTo、To & Action ノードを削除しています。エンドポイント動作クラスのデバッグ中にエラーは表示されませんが、BizTalk NACK で「メッセージの送信中に内部サーバー エラーが発生しました」というエラーが表示され続けます。エンドポイント動作クラスの BeforeSendRequest メソッドのコードは次のとおりです。

public object BeforeSendRequest(ref Message request, IClientChannel channel)
{
    try
    {
        MessageBuffer messageBuffer = request.CreateBufferedCopy(Int32.MaxValue);
        Message message = messageBuffer.CreateMessage();
        messageBuffer.Close();

        MemoryStream msOriginal = new MemoryStream();
        XmlWriter xwOriginal = XmlWriter.Create(msOriginal);
        message.WriteMessage(xwOriginal);
        xwOriginal.Flush();
        string originalMsg = Encoding.UTF8.GetString(msOriginal.ToArray());
        xwOriginal.Close();

        msOriginal.Position = 0;

        msOriginal = new MemoryStream(Encoding.UTF8.GetBytes(originalMsg));
        XmlDictionaryReader xdrOriginal = XmlDictionaryReader.CreateTextReader(msOriginal, new XmlDictionaryReaderQuotas());
        XDocument xdoc = XDocument.Load(xdrOriginal);

        var rootMsgElement = xdoc.Root;
        //string rootNameSpace = "http://www.w3.org/2003/05/soap-envelope"; // string.Empty;
        string nameSpace = "http://www.w3.org/2005/08/addressing";

        //if (rootMsgElement.Name.LocalName == XName.Get("Envelope", rootNameSpace))
        //{
            if (!string.IsNullOrEmpty(xdoc.Descendants(XName.Get("Action", nameSpace)).First().Value) || !string.IsNullOrEmpty(xdoc.Descendants(XName.Get("MessageID", nameSpace)).First().Value) || !string.IsNullOrEmpty(xdoc.Descendants(XName.Get("ReplyTo", nameSpace)).First().Value) || !string.IsNullOrEmpty(xdoc.Descendants(XName.Get("To", nameSpace)).First().Value))
            {
                xdoc.Descendants(XName.Get("Action", nameSpace)).Remove();
                xdoc.Descendants(XName.Get("MessageID", nameSpace)).Remove();
                xdoc.Descendants(XName.Get("ReplyTo", nameSpace)).Remove();
                xdoc.Descendants(XName.Get("To", nameSpace)).Remove();
            }
        //}
        string updatedMsgString = rootMsgElement.ToString();
        // xdoc.Save(updatedMsgString);

        Message recreatedNewMessage = null;
        msOriginal = new MemoryStream(Encoding.UTF8.GetBytes(updatedMsgString));
        msOriginal.Position = 0;
        XmlDictionaryReader newXdr = XmlDictionaryReader.CreateTextReader(msOriginal, new XmlDictionaryReaderQuotas());
        recreatedNewMessage = Message.CreateMessage(newXdr, int.MaxValue, request.Version);
        recreatedNewMessage.Properties.CopyProperties(request.Properties);

        request = recreatedNewMessage;
    }
    catch (Exception ex)
    {
        string errorMsg = ex.Message;
        if (ex.InnerException != null)
        {
            errorMsg += ex.InnerException.Message;
        }
    }
    return request;
}

ご覧のとおり、ストリームの位置を 0 に戻そうとしましたが、それでも解決しません。また、Message sans MessageID、ReplyTo、To & Action ノードをエンドポイントに直接プッシュしようとしましたが、適切な応答が取得されます。ここで何か不足している場合はお知らせください。

4

0 に答える 0