1

こんにちは、操作が装飾されている場合、メッセージにカスタム ヘッダーを挿入する必要があります。

私はこれまでに何をしましたか？1) Attribute と IOperationBehavior を継承して Attribute を作成 2) 操作にカスタム OperationInvoker をアタッチ

属性：

public class RankAttribute : Attribute, IOperationBehavior
{ 
     public void ApplyDispatchBehavior(OperationDescription operationDescription, DispatchOperation dispatchOperation)
    {
        dispatchOperation.Invoker = new PublishMessageInvoker(dispatchOperation.Invoker);
    }
    //rest of the methods
}

インターフェース：

public interface INullableService
{
    [OperationContract]
    [FaultContract(typeof(BusinessServiceException))]
    [Rank]
    NullableResponse NullChecking(NullableRequest request);

    [OperationContract]
    [FaultContract(typeof(BusinessServiceException))]
    NullableResponse NullChecking2(NullableRequest request);
}

ここでの問題は、メッセージ ヘッダーを変更する場所がわからないことです。operationDiscription.Messages[] を介してメッセージにアクセスできますが、ドキュメントには、変更すると予期しない結果が生じると記載されています。

ありがとう、アビナッシュ

4

1 に答える 1

1

気にしないでください:)それは些細なことでした:) .. IOperationInvokerでOperationContextにアクセスできます

public class PublishMessageInvoker : IOperationInvoker
{
    private IOperationInvoker invoker;


    public PublishMessageInvoker(IOperationInvoker invoker)
    {
        logger.Info("PublishMessageInvoker");
        this.invoker = invoker;

    }

    public object[] AllocateInputs()
    {

        if (invoker == null)
            return null;
        return this.invoker.AllocateInputs();
    }

    public object Invoke(object instance, object[] inputs, out object[] outputs)
    {
       OperationContext.Current.OutgoingMessageHeaders.Add(
            MessageHeader.CreateHeader(
                "customheader",
                "asnjnjdhbhb.com",
                "MyAction")
                );
        return this.invoker.Invoke(instance, inputs, out outputs);
    }

    public IAsyncResult InvokeBegin(object instance, object[] inputs, AsyncCallback callback, object state)
    {

        if (invoker == null)
            return null;
        return this.invoker.InvokeBegin(instance, inputs, callback, state);
    }

    public object InvokeEnd(object instance, out object[] outputs, IAsyncResult result)
    {

        if (invoker == null)
        {
            outputs = null;
            return null;
        }
        return this.invoker.InvokeEnd(instance, out outputs, result);
    }

    public bool IsSynchronous
    {
        get {

            if (invoker == null) return true;
            return this.invoker.IsSynchronous; 
        }
    }
}
于 2013-09-27T12:18:05.760 に答える