1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
//----------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//----------------------------------------------------------------
namespace System.ServiceModel.Activities.Description
{
using System.Activities.Statements;
using System.Collections.ObjectModel;
using System.Diagnostics;
using System.Globalization;
using System.Runtime;
using System.ServiceModel.Channels;
using System.ServiceModel.Description;
using System.ServiceModel.Dispatcher;
using System.Runtime.DurableInstancing;
using System.Collections.Generic;
using System.Threading;
using System.ServiceModel.Diagnostics;
using System.Activities;
[Obsolete("The WF3 types are deprecated. Instead, please use the new WF4 types from System.Activities.*")]
public class WorkflowRuntimeEndpoint : WorkflowHostingEndpoint
{
static readonly Uri baseUri = new Uri(string.Format(CultureInfo.InvariantCulture, "net.pipe://localhost/ExternalDataExchangeEndpoint/{0}/{1}",
Process.GetCurrentProcess().Id,
AppDomain.CurrentDomain.Id));
static int uriCounter = 0;
internal static readonly Binding netNamedPipeContextBinding = new CustomBinding(new ContextBindingElement(),
new BinaryMessageEncodingBindingElement(),
new NamedPipeTransportBindingElement()) { Name = "ExternalDataExchangeBinding" };
WorkflowRuntimeServicesBehavior behavior;
internal const string ExternalDataExchangeNamespace = "http://wf.microsoft.com/externaldataexchange/";
internal const string RaiseEventAction = "http://wf.microsoft.com/externaldataexchange/IExternalDataExchange/RaiseEvent";
public WorkflowRuntimeEndpoint()
: base(typeof(IExternalDataExchange))
{
base.Binding = netNamedPipeContextBinding;
string endpointUri = String.Format(CultureInfo.InvariantCulture, "{0}/{1}", baseUri, Interlocked.Increment(ref uriCounter));
base.Address = new EndpointAddress(endpointUri);
this.behavior = new WorkflowRuntimeServicesBehavior();
this.Behaviors.Add(behavior);
}
protected override Guid OnGetInstanceId(object[] inputs, OperationContext operationContext)
{
Fx.Assert(operationContext.IncomingMessageHeaders.Action == RaiseEventAction, "Message action is not RaiseEvent");
Guid instanceId = Guid.Empty;
ContextMessageProperty contextMessageProperty;
if (ContextMessageProperty.TryGet(operationContext.IncomingMessageProperties, out contextMessageProperty))
{
string stringInstanceId = null;
if (contextMessageProperty.Context.TryGetValue("instanceId", out stringInstanceId))
{
Fx.TryCreateGuid(stringInstanceId, out instanceId);
}
}
return instanceId;
}
protected override Bookmark OnResolveBookmark(object[] inputs, OperationContext operationContext, WorkflowHostingResponseContext responseContext, out object value)
{
Fx.Assert(operationContext.IncomingMessageHeaders.Action == RaiseEventAction, "Message action is not RaiseEvent");
Fx.Assert(inputs.Length >= 3, "Insufficient number of inputs");
Fx.Assert(inputs[1] is IComparable, "The queue name from ExternalDataExchangeService is not an IComparable object");
IComparable queueName = (IComparable)inputs[1];
value = inputs[2];
responseContext.SendResponse(null, null);
return new Bookmark(queueName.ToString());
}
public void AddService(object service)
{
behavior.AddService(service);
}
public void RemoveService(object service)
{
behavior.RemoveService(service);
}
public object GetService(Type serviceType)
{
return behavior.GetService(serviceType);
}
public T GetService<T>()
{
return behavior.GetService<T>();
}
}
}
|
