I’ve just uploaded an
updated version of my PipelineTesting library
for BizTalk Server 2006. This version fixes an issue that Gregory
Van de Wiele pointed to me a couple of weeks ago. Thanks Gregory!
The issue was that when I added Transaction support to the pipeline library, I didn’t
provide a way to control the transaction lifetime, or worse, the transaction end result.
What ended up happening was that if you called EnableTransactions() on the pipeline,
the transaction was created on demand when one component in the pipeline called IPipelineContextEx.GetTransaction().
However, nowhere did I explicitly release the transaction nor called Commit()
or Rollback() on it causing fairly ugly issues because the transaction release
was left to the GC.
Fixing this issue did imply I had to make a breaking change in the API, but hopefully
not one too bad. I changed the EnableTransactions() method in the pipeline classes
to return a TransactionControl object that you could use to control transaction lifetime
and result. Basically, this one works pretty much like the TransactionScope class
in System.Transactions: You wrap it in a using() declaration and if you want to commit,
you cal SetComplete() on it just before disposing it. Here’s an example of using the
pipeline with the transaction support enabled:
public void CanCreateTransaction()
{
SendPipelineWrapper pipeline =
PipelineFactory.CreateSendPipeline(typeof(XMLTransmit));
using ( TransactionControl control = pipeline.EnableTransactions() )
{
// Create the input message to pass through the pipeline
Stream stream = DocLoader.LoadStream(“SampleDocument.xml”);
IBaseMessage inputMessage = MessageHelper.CreateFromStream(stream);
// Add the necessary schemas to the pipeline, so that
// disassembling works
pipeline.AddDocSpec(typeof(Schema1_NPP));
pipeline.AddDocSpec(typeof(Schema2_WPP));
MessageCollection inputMessages = new MessageCollection();
inputMessages.Add(inputMessage);
// Execute the pipeline, and check the output
IBaseMessage outputMessage = pipeline.Execute(inputMessages);
Assert.IsNotNull(outputMessage);
control.SetComplete();
}
}
Enjoy.