首页 > 代码库 > BizTalk开发系列(十一) 在Orchestration中执行Pipeline
BizTalk开发系列(十一) 在Orchestration中执行Pipeline
由于开发需要有时要在流程中执行Pipeline。比如从DB的某个字段中取消息的字符串并在流程中构造消息。该需要通过pipeline进行升级 属性字段,验证消息等处理。BizTalk架构已经开放了此接口: XLANGPipelineManage类,以下为在流程中使用接收和发送端口示例。需在项目中引用Microsoft.XLANGs.Pipeline 组件(C:\Program Files\Microsoft BizTalk Server 2006\Microsoft.XLANGs.Pipeline.dll)
1.使用接收管道
- 在XLANGPipelineManage类中调用ExecuteReceivePipeline()执行接收管道。
XLangPipelineMangae类中的方法代码:
- 在流程中新建一个变量 vRecOut 类型为:ReceivePipelineOutputMessages
- 新建一个消息 SchMsg 类型为定义的Schema
- 在构造消息表达式的值为:
ExecuteReceivePipeline(typeof (TestPipelines.MyRecPipeline),InputMsg);
SchMsg =null; //初始化输出消息。
vRecOut .MoveNext(); //IElement的默认方法。
vRecOut .GetCurrent(SchMsg );
TestPipelines.MyRecPipeline 为管道的Fully Qualified Name(完全限定名称),包括命名空间和类名。
InputMsg 为输入的消息,也就是要传到管道处理的消息。
2.使用发送管道
- 调用ExecuteSendPipeline()执行发送管道。
XLangPipelineMangae类中的方法代码:
- 在流程中新建一个变量 vInMsgs 类型为SendPipelineInputMessages
- 新建一个消息 SendMsg 类型为Send Pipeline处理之后的消息。
- 在构造消息的表达式的值为:
SendMsg=null;
Microsoft.XLANGs.Pipeline.XLANGPipelineManager.ExecuteSendPipeline(typeof(TestPipelines.MySendPipeline),vInMsgs,SendMsg);
TestPipelines.MySendPipeline为管道的Fully Qualified Name(完全限定名称),包括命名空间和类名。
InputMsg 为输入的消息,也就是要传到管道处理的消息
注意:构造消息需要在构造形状里执行,并且在构造形状的属性里选择要构造的消息否则会报如下错误
Illegal attempt to update the value of part ‘part‘ in XLANG/s message ‘InputMsg‘ after the message construction was complete
BizTalk开发系列(十一) 在Orchestration中执行Pipeline