NUnit Test for Custom Pipelines

[quote:eb983a3758=\”beewil \”]Is there any documentation for testing custom pipelines with nunit.

We have created a custom pipeline using the HL7 accelerater and we would like add some unit testing functionality to the project.

I’m having problems creating the IPipelineContext and the IBaseMessage

Help![/quote:eb983a3758]

In fact, going further, to make this completely programmatic you can make use of the PipelineObjects assembly in the same location. You can call this as shown below to exceute an arbitrary pipeline as a unit test.

In this case I am just calling the standard passthru receive pipeline and passing a simple xml message. I then output the resulting message at the end of the pipeline showing the same message as was entered.

PipelineFactory factory = new PipelineFactory();

string pipelineName = \”Microsoft.BizTalk.DefaultPipelines.PassThruReceive, Microsoft.BizTalk.DefaultPipelines, Version=3.0.1.0, Culture=neutral, PublicKeyToken=31bf3856ad364e35\”;

IPipeline p = factory.CreatePipelineFromType(pipelineName);

MessageFactory msgFactory = new MessageFactory();
IBaseMessage message = msgFactory.CreateMessage ();
IBaseMessageContext context = msgFactory.CreateMessageContext();
PipelineContext ctx = new PipelineContext();

XmlDocument doc = new XmlDocument();
doc.LoadXml(\”<test><this>is a test</this></test>\”);

IBaseMessagePart part = msgFactory.CreateMessagePart();
Stream s = new MemoryStream();
doc.Save(s);
s.Seek(0,0);
part.Data = s;
message.AddPart(\”part\”,part,true);
p.InputMessages.Add (message);

p.Execute(ctx);

IBaseMessage output = p.GetNextOutputMessage(ctx);
while (output != null)
{
byte[] buffer = new byte[output.BodyPart.Data.Length];
output.BodyPart.Data.Read(buffer,0,(int)output.BodyPart.Data.Length);
System.Text.ASCIIEncoding encoding = new System.Text.ASCIIEncoding();
string result = new string(encoding.GetChars(buffer));
Console.WriteLine(result);
output = p.GetNextOutputMessage(ctx);
}

you’ll need to add the following ‘using’ clauses to the class file to compile it:

using Microsoft.BizTalk.Message.Interop; // from microsoft.biztalk.pipeline.dll
using Microsoft.Test.BizTalk.PipelineObjects; // from PipelineObjects.dll
using System.Xml;
using System.IO;