The Problem Solver

private static WorkflowElement CreateWorkflow()

{

    var result = new Sequence();

    var input = new Variable<Person>();

    result.Variables.Add(input);

    XNamespace ns = "http://tempuri.org";

    var handle1 = new Variable<CorrelationHandle>();

    result.Variables.Add(handle1);

    var handle2 = new Variable<CorrelationHandle>();

    result.Variables.Add(handle2);

    var receive1 = new Receive()

    {

        OperationName = "Operation1",

        ServiceContractName = ns + "MyService",

        Value = new OutArgument<Person>(input),

        AdditionalCorrelations = {                   

           {"ChannelBasedCorrelation", new InArgument<CorrelationHandle>(handle1)}

        },

        CorrelationQuery = CreateCorrelationQuery(),

        CanCreateInstance = true

    };

    result.Activities.Add(receive1);

    var write1 = new WriteLine()

    {

        Text = new InArgument<string>(env => string.Format("\tThe workflow was called with '{0}'.", input.Get(env)))

    };

    result.Activities.Add(write1);

    var reply1 = new SendReply()

    {

        Request = receive1,

        Value = new InArgument<string>("The result")

    };

    result.Activities.Add(reply1);

    var receive2 = new Receive()

    {

        OperationName = "Operation2",

        ServiceContractName = ns + "MyService",

        Value = new OutArgument<Person>(input),

        AdditionalCorrelations = {

           {"ChannelBasedCorrelation", new InArgument<CorrelationHandle>(handle2)}

        },

        CorrelationQuery = CreateCorrelationQuery()

    };

    result.Activities.Add(receive2);

    var write2 = new WriteLine()

    {

        Text = new InArgument<string>(env => string.Format("\tThe workflow was called again with '{0}'.", input.Get(env)))

    };

    result.Activities.Add(write2);

    var reply2 = new SendReply()

    {

        Request = receive2,

        Value = new InArgument<string>("The second result")

    };

    result.Activities.Add(reply2);

    return result;

}

private static CorrelationQuery CreateCorrelationQuery()

{

    var result = new CorrelationQuery();

    var xpath = new XPathMessageQuery()

    {

        Namespaces = new XmlNamespaceManager(new NameTable()),

        Expression = "//sample:Person/sample:Id"

    };

    xpath.Namespaces.AddNamespace("sample", "urn:WF4Sample:person");

    var messageQuerySet = new MessageQuerySet()

    {

        Name = "RequestCorrelation"

    };

    messageQuerySet.Add("PersonId", xpath);

    result.Select = messageQuerySet;

    return result;

}

[ServiceContract]

interface MyService

{

    [OperationContract]

    Operation1Response Operation1(Person request);

    [OperationContract]

    Operation1Response Operation2(Person request);

}

static void Main(string[] args)

{

    var binding = new BasicHttpBinding();

    var endpoint = new EndpointAddress("http://localhost:8090/Sequence1/Operation1");

    var factory = new ChannelFactory<MyService>(binding, endpoint);

    var proxy = factory.CreateChannel();

    var request = new Person()

    {

        Id = 23,

        FirstName = "Joe",

        LastName = "Regular",

        BirthDate = new DateTime(1975, 7, 1)

    };

    var result = proxy.Operation1(request);

    Console.WriteLine(result.Value);

    //request.Id = 99;

    request.FirstName = "Maurice";

    request.LastName = "Chevalier";

    request.BirthDate = new DateTime(1888, 9, 12);

    result = proxy.Operation2(request);

    Console.WriteLine(result.Value);

    Console.WriteLine("Regular client is done.");

    Console.ReadLine();

}

private static WorkflowElement CreateWorkflow()

{

    var result = new Sequence();

    XNamespace ns = "http://tempuri.org";

    var endpoint = new Endpoint()

    {

        Uri = new Uri("http://localhost:8090/Sequence1/Operation1"),

        Binding = new BasicHttpBinding()

    };

    var response = new Variable<string>();

    result.Variables.Add(response);

    var handle = new Variable<CorrelationHandle>();

    result.Variables.Add(handle);

    var person = new Person()

    {

        Id = 7,

        FirstName = "Maurice",

        LastName = "de Beijer",

        BirthDate = new DateTime(1962, 8, 24)

    };

    var request = new Send()

    {

        OperationName = "Operation1",

        Endpoint = endpoint,

        AdditionalCorrelations =

        {

           {"ChannelBasedCorrelation", new InArgument<CorrelationHandle>(handle)}

        },

        ServiceContractName = ns + "MyService",

        Value = new InArgument<Person>(person)

    };

    result.Activities.Add(request);

    var reply = new ReceiveReply()

    {

        Request = request,

        Value = new OutArgument<string>(response)

    };

    result.Activities.Add(reply);

    var write = new WriteLine()

    {

        Text = new InArgument<string>(response)

    };

    result.Activities.Add(write);

    var delay = new Delay()

    {

        Duration = TimeSpan.FromSeconds(5)

    };

    result.Activities.Add(delay);

    var request2 = new Send()

    {

        OperationName = "Operation2",

        Endpoint = endpoint,

        AdditionalCorrelations =

        {

           {"ChannelBasedCorrelation", new InArgument<CorrelationHandle>(handle)}

        },

        ServiceContractName = ns + "MyService",

        Value = new InArgument<Person>(person)

    };

    result.Activities.Add(request2);

    var reply2 = new ReceiveReply()

    {

        Request = request2,

        Value = new OutArgument<string>(response)

    };

    result.Activities.Add(reply2);

    var write2 = new WriteLine()

    {

        Text = new InArgument<string>(response)

    };

    result.Activities.Add(write2);

    return result;

}