Pipeline Testing Library Updated

I've just now updated my Pipeline Testing Library. In this version, I've created my own mock IPipelineContext[Ex] implementation, to support configuring some functionality not previously available:

1. You can now configure at the pipeline level the thumbprint for the Group Signing Certificate so that it is returned from IPipelineContext.GroupSigningCertificate to pipeline components. Here's how you'd configure it:
   
   
   

   SendPipelineWrapper pipeline = PipelineFactory.CreateEmptySendPipeline();

   
   

   pipeline.GroupSigningCertificate = "....";
   

   
   
2. Now transactional support is available for pipeline components if you enable it (it's disabled by default). If you do enable it, then components will get a valid DTC transaction returned from IPipelineContextEx.GetTransaction(). I'm not 100% comfortable with this, but it can be useful in a few scenarios (see below for one such one). To enable it, call the EnableTransactions() method on the pipeline wrapper object just before calling Execute().

The reason why I implemented the transactional support in the pipeline context mock object is that some components require it. In particular, it turns out that the BizTalk Framework Disassembler Component (BtfDasmComp) will not work unless the pipeline context returns a valid transaction from IPipelineContextEx.GetTransaction().  With this update, you can now test pipelines that use the BtfDasmComp component, though be aware that the transaction object is then used to access some of the biztalk databases (I'm not exactly sure yet what for, though). Here's an example piece of code with such a trick:

ReceivePipelineWrapper pipeline = PipelineFactory.CreateEmptyReceivePipeline();

pipeline.AddComponent(new BtfDasmComp(), PipelineStage.Disassemble);

FixEncodingComponent fix = new FixEncodingComponent();

fix.Encoding = Encoding.Unicode;

pipeline.AddComponent(fix, PipelineStage.Decode);

pipeline.EnableTransactions();

Stream input = new FileStream(@"e:\temp\BtfDasmTest\BOBUILDING_SITE2.xml", FileMode.Open);

IBaseMessage inputMsg = MessageHelper.CreateFromStream(input);

MessageCollection outputMsgs = pipeline.Execute(inputMsg);