Совместное использование CorrelationHandle между двумя пользовательскими действиями с использованием аргументов - PullRequest
Новая
       23

Совместное использование CorrelationHandle между двумя пользовательскими действиями с использованием аргументов

0 голосов
/ 27 октября 2011

Я создаю пользовательские действия. Первое действие содержит действие ReceiveSendReply с некоторыми другими действиями. В этом упражнении я создаю экземпляр рабочего процесса. Я хочу назначить Intialized CorrelationHandle для OutArgument. Который будет присвоен внешнему общедоступному варианту.

В другом действии у меня есть другое действие ReceiveSendReply, которое возобновит экземпляр, созданный вышеупомянутым действием. Во втором действии у меня есть CorrelationHandle как InArgument. Я назначу этот InArgument с помощью внешнего общего параметра correlationHandle.

Когда я выполняю эту службу рабочего процесса, первая операция выполняется без проблем, и она заполняет ключ корреляции, и я получаю этот ключ корреляции в ответе. Когда я выполняю второе действие, используя полученный ключ корреляции, сервис возвращается со следующим исключением:

"Выполнение InstancePersistenceCommand было прервано, потому что ключ экземпляра '45f99690-2829-3126-0782-99033212633c' не был связан с экземпляром. Это может произойти из-за того, что экземпляр или ключ был очищен или потому что ключ недействительный. Ключ может быть недействительным, если сообщение, из которого он был сгенерирован, было отправлено в неправильное время или содержало неверные данные корреляции. "

Я хочу знать, как использовать CorrelationHandle между двумя пользовательскими действиями с помощью OutArgument и InArguments? 

public sealed class Create : Activity
{
    public Create()
    {
        Implementation = new Func<Activity>(CreateBody);
    }

    public string ServiceContract { get; set; }

    public string Operation { get; set; }

    [RequiredArgument]
    public OutArgument<CorrelationHandle> CorrelationHandle { get; set; }

    Activity CreateBody()
    {
        // variables declaration. 
        var requestContent = new Variable<string>();
        var operationResponseParam = new Variable<OperationResponseParam>();
        var correlationKey = new Variable<string>();
        var correlationHandle = new Variable<CorrelationHandle>();

        Receive receiveRequest;

        return new Sequence
        {
            Variables = { correlationHandle, correlationKey }, 
            Activities = 
            {
                {receiveRequest = new Receive()
                {
                    ServiceContractName = ServiceContract,
                    OperationName = Operation,
                    CanCreateInstance = true,
                    Content = new ReceiveMessageContent
                    {
                        Message = new OutArgument<string>(ctx => operationRequestParam.Get(ctx))
                    },
                }},

                new Assign<string>
                {
                    To = new OutArgument<string>(ctx => correlationKey.Get(ctx)),
                    Value = new InArgument<string>(ctx => Guid.NewGuid().ToString())
                },

                new Assign<ApplicationDataList>
                {
                    To = new ArgumentReference<ApplicationDataList>("AppData"),
                    Value = new InArgument<ApplicationDataList>(ctx =>appData.Get(ctx))
                },

                new Assign<OperationResponseParam>
                {
                    To = new OutArgument<OperationResponseParam>(ctx => operationResponseParam.Get(ctx)),
                    Value = new InArgument<OperationResponseParam>
                    {
                        Expression = new BuildResponse()
                        {
                            CorrelationKey = new InArgument<string>(correlationKey),
                        }
                    }
                },

                new SendReply
                {
                    Request = receiveRequest,
                    Content = new SendMessageContent
                    {
                        Message = new InArgument<OperationResponseParam>(ctx => operationResponseParam.Get(ctx))
                    },

                    CorrelationInitializers =
                    {
                        new QueryCorrelationInitializer
                        {
                            CorrelationHandle =  new InArgument<CorrelationHandle>(correlationHandle),
                            MessageQuerySet = new MessageQuerySet
                            {
                                {
                                    "CorrelationKey", new XPathMessageQuery("sm:header()/tempuri:CorrelationKey")
                                }
                            }
                        }
                    }
                },

                new Assign<CorrelationHandle>
                {
                    To = new ArgumentReference<CorrelationHandle>("CorrelationHandle"),
                    Value = new InArgument<CorrelationHandle>(ctx =>correlationHandle.Get(ctx))
                },
            }
        };
    }
}


public sealed class Wait : Activity
{
    public Wait()
    {
        Implementation = new Func<Activity>(CreateBody);
    }

    public string ServiceContract { get; set; }

    public string Operation { get; set; }

    [RequiredArgument]
    public InArgument<CorrelationHandle> CorrelationHandle { get; set; }

    Activity CreateBody()
    {
        // variables declaration. 

        var operationRequestParam = new Variable<OperationRequestParam>();
        var operationResponseParam = new Variable<OperationResponseParam>();
        var correlationHandle = new Variable<CorrelationHandle>();
        Receive receiveRequest;

        return new Sequence
        {
            Variables = { correlationHandle },
            Activities =
            {
                new Sequence
                {
                    Variables = {operationRequestParam, operationResponseParam },

                    Activities = 
                    {
                        {receiveRequest =new Receive()
                        {
                            ServiceContractName = ServiceContract,
                            OperationName = Operation,
                            CanCreateInstance = false,
                            CorrelatesWith = new InArgument<CorrelationHandle>(ctx => CorrelationHandle.Get(ctx)),
                            CorrelatesOn = new MessageQuerySet
                            {
                                { "CorrelationKey", new XPathMessageQuery("sm:header()/tempuri:CorrelationKey")}
                            },

                            //parameters for receive
                            Content = new ReceiveMessageContent
                            {
                                Message = new OutArgument<OperationRequestParam>(ctx => operationRequestParam.Get(ctx))
                            },
                        }},


                        new Assign<OperationResponseParam>
                        {
                            To = new OutArgument<OperationResponseParam>(operationResponseParam),
                            Value = new InArgument<OperationResponseParam>
                            {
                                Expression = new BuildResponse()
                                {
                                    ApplicationData = new InArgument<ApplicationDataList>(ctx => appData.Get(ctx)),
                                }
                            }
                        },

                        new SendReply
                        {
                            Request = receiveRequest,
                            Content = new SendMessageContent
                            {
                                Message = new InArgument<OperationResponseParam>(ctx => operationResponseParam.Get(ctx))
                            }
                        },
                    }
                },
            }
        };
    }
}

1 Ответ

1 голос
/ 29 октября 2011

Мы должны использовать дескриптор в качестве InArgument, и объект, ссылающийся на дескриптор, будет изменен InitializeCorrelation.Так что в обоих моих действиях я должен использовать InArgument вместо OutArgument в первом и InArgument во втором.

public sealed class Create : Activity
{
    public Create()
    {
        Implementation = new Func<Activity>(CreateBody);
    }

    public string ServiceContract { get; set; }

    public string Operation { get; set; }

    [RequiredArgument]
    public InArgument<CorrelationHandle> CorrelationHandle { get; set; }

    Activity CreateBody()
    {
        // variables declaration. 
        var operationRequestParam = new Variable<OperationRequestParam>();
        var appData = new Variable<ApplicationDataList>();
        var operationResponseParam = new Variable<OperationResponseParam>();
        var correlationKey = new Variable<string>();


        Receive receiveRequest;

        return new Sequence
        {
            Variables = { correlationKey }, 
            Activities = 
            {
                {receiveRequest = new Receive()
                {
                    ServiceContractName = ServiceContract,
                    OperationName = Operation,
                    CanCreateInstance = true,
                    //parameters for receive
                    Content = new ReceiveMessageContent
                    {
                        Message = new OutArgument<string>(ctx => operationRequestParam.Get(ctx))
                    },
                }},

                // Assign a unique identifier to the correlation key.
                new Assign<string>
                {
                    To = new OutArgument<string>(ctx => correlationKey.Get(ctx)),
                    Value = new InArgument<string>(ctx => Guid.NewGuid().ToString())
                },

                new Assign<OperationResponseParam>
                {
                    To = new OutArgument<OperationResponseParam>(ctx => operationResponseParam.Get(ctx)),
                    Value = new InArgument<OperationResponseParam>
                    {
                        Expression = new BuildResponse()
                        {
                            CorrelationKey = new InArgument<string>(correlationKey),
                        }
                    }
                },

                new SendReply
                {
                    Request = receiveRequest,
                    Content = new SendMessageContent
                    {
                        Message = new InArgument<string>(ctx => operationResponseParam.Get(ctx))
                    },

                    CorrelationInitializers =
                    {
                        new QueryCorrelationInitializer
                        {
                            CorrelationHandle =  new InArgument<CorrelationHandle>(ctx => CorrelationHandle.Get(ctx)),
                            MessageQuerySet = new MessageQuerySet
                            {
                                {
                                    "CorrelationKey", new XPathMessageQuery("sm:header()/tempuri:CorrelationKey")
                                }
                            }
                        }
                    }
                },
            }
        };
    }
}

public sealed class Wait : Activity
{
    static Wait()
    {
        AttributeTableBuilder builder = new AttributeTableBuilder();
        builder.AddCustomAttributes(typeof(Wait), "EscalationData", new EditorAttribute(typeof(EscalationDataEditor), typeof(DialogPropertyValueEditor)));
        MetadataStore.AddAttributeTable(builder.CreateTable());
    }

    public Wait()
    {
        Implementation = new Func<Activity>(CreateBody);
    }

    public EscalationInfoList EscalationData { get; set; }

    public string ServiceContract { get; set; }

    public string Operation { get; set; }

    [RequiredArgument]
    public InArgument<CorrelationHandle> CorrelationHandle { get; set; }

    Activity CreateBody()
    {
        // variables declaration. 
        var appData = new Variable<ApplicationDataList>();
        var operationRequestParam = new Variable<OperationRequestParam>();
        var operationResponseParam = new Variable<OperationResponseParam>();

        Receive receiveRequest;

        return new Sequence
        {
            Activities =
            {
               new Sequence
               {
                    Variables = {operationRequestParam, operationResponseParam },

                    Activities = 
                    {
                        {receiveRequest =new Receive()
                        {
                            ServiceContractName = ServiceContract,
                            OperationName = Operation,
                            CanCreateInstance = false,
                            CorrelatesWith = new InArgument<CorrelationHandle>(ctx => CorrelationHandle.Get(ctx)),
                            CorrelatesOn = new MessageQuerySet
                            {
                                { "CorrelationKey", new XPathMessageQuery("sm:header()/tempuri:CorrelationKey")}
                            },

                            //parameters for receive
                            Content = new ReceiveMessageContent
                            {
                                Message = new OutArgument<OperationRequestParam>(ctx => operationRequestParam.Get(ctx))
                            },
                        }},

                        new SendReply
                        {
                            Request = receiveRequest,
                            Content = new SendMessageContent
                            {
                                Message = new InArgument<OperationResponseParam>(ctx => operationResponseParam.Get(ctx))
                            }
                        },
                    }
                },
            }
        }
    }
}
...