Как я могу изменить сообщение в DuplexSessionChannel (tcpTransport) в пользовательском канале WCF?

Question

Я реализую IDuplexSessionChannel на своем канале, потому что я использую tcpTransport. В этом пользовательском канале я кеширую ответ на вызов службы (кэширование на стороне клиента). Но в этом есть ошибки. В IRequestChannel все работает нормально. Как я могу изменить сообщение в методе TryMessage. Мой код:

public Message Receive(TimeSpan timeout)
    {
        Message response = null;
        response = CommunicationCacheManager.Get(_request.Headers.Action, _request);

        if (response == null)
        {
            response = this.InnerChannel.Receive(timeout);
            int cacheTimeout = 0;
            if (response.Headers.FindHeader(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE) > -1)
            {
                cacheTimeout = response.Headers.GetHeader<int>(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE);
            }
            if (cacheTimeout > 0 && response != null &&
                    !response.IsFault &&
                    !response.IsEmpty)
            {
                CommunicationCacheManager.Add(_request.Headers.Action, cacheTimeout, ref response);
            }
        }
        return response;
    }

    public Message Receive()
    {
        return this.InnerChannel.Receive();
    }

    public bool TryReceive(TimeSpan timeout, out Message message)
    {
        ThrowIfDisposedOrNotOpen();
        message = null;
        bool timedout = false;
        try
        {
            message = this.Receive(timeout);
        }
        catch (TimeoutException)
        {
            timedout = true;
        }
        return (!timedout);
    }

CacheManager работает. И я получаю ответ Кеша. Но попробуйте получить снова запустить и когда я смотрю сообщение. Сообщение закрыто. Как я могу это исправить

Answer 1

Проблема решена.

Tcp Binding добавляет RelatesTo Header к сообщению. Таким образом, код изменен на

public Message Receive(TimeSpan timeout)
{
    Message response = null;
    response = CommunicationCacheManager.Get(_request.Headers.Action, _request);

    if (response == null)
    {
        response = this.InnerChannel.Receive(timeout);
        int cacheTimeout = 0;
        if (response.Headers.FindHeader(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE) > -1)
        {
            cacheTimeout = response.Headers.GetHeader<int>(Constants.CacheTimeOutHeader.NAME, Constants.CacheTimeOutHeader.NAMESPACE);
        }
        if (cacheTimeout > 0 && response != null &&
                !response.IsFault &&
                !response.IsEmpty)
        {
            CommunicationCacheManager.Add(_request.Headers.Action, cacheTimeout, ref response);
        }
    }
    else
    {
       response.Headers.RelatesTo=_request.Header.MessageId;
    }
    return response;
}