private Dictionary<Guid, Stream> PrepareForParsing()

        {

            Dictionary<Guid, Stream> d = new Dictionary<Guid, Stream>();

            foreach (IBaseMessage bm in _inmsgs)

            {

                if (bm.BodyPartName == r_BodyName)

                {

                    for (int i = 0; i < bm.PartCount; ++i)

                    {

                        string partName = string.Empty;

                        IBaseMessagePart bmp = bm.GetPartByIndex(i, out partName);

                        Guid Name = r_BodyName == partName ? Guid.Empty : new Guid(partName);

                        if (!d.ContainsKey(Name))

                        {

                            Stream s = bmp.GetOriginalDataStream();

                            s.Position = 0;

                            d.Add(Name, s);

                        }

                    }

                }

                else

                {

                    Guid Name = GetInternalName(bm);

                    Stream s = bm.BodyPart.GetOriginalDataStream();

                    s.Position = 0;

                    if (d.ContainsKey(Name))

                        d[Name] = s;

                    else

                        d.Add(Name, s);

                }

            }

            return d;

        }

private Stream ComposeMessage(Dictionary<Guid, Stream> dvn)

        {

            MemoryStream stream = new MemoryStream();

            using (XmlReader reader = XmlReader.Create(dvn[Guid.Empty]))

            {

                using (XmlWriter writer = XmlWriter.Create(stream))

                {

                    while (reader.Read())

                    {

                        if (reader.NodeType == XmlNodeType.Element &&

                            reader.LocalName == r_TagName)

                        {

                            reader.Read();

                            Guid g = new Guid(reader.Value);

                            if (!dvn.ContainsKey(g))

                            {

                                writer.WriteElementString(r_TagName, g.ToString());

                            }

                            else

                            {

                                using (XmlReader partReader = XmlReader.Create(dvn[g]))

                                {

                                    reader.Read();//read guid end tag

                                    do

                                    {

                                        if (partReader.NodeType != XmlNodeType.XmlDeclaration)

                                            PipelineUtils.Util.WriteShallowNode(partReader, writer);

                                    }

                                    while (partReader.Read());

                                    dvn[g].Position = 0;

                                }

                            }

                        }

                        else PipelineUtils.Util.WriteShallowNode(reader, writer);

                    }

                }

            }

            stream.Position = 0;

            return stream;

        }

public Microsoft.BizTalk.Message.Interop.IBaseMessage Assemble(Microsoft.BizTalk.Component.Interop.IPipelineContext pc)

        {

            Dictionary<Guid, Stream> dvn = PrepareForParsing();

            IBaseMessageFactory bmf = pc.GetMessageFactory();

            IBaseMessage bm = bmf.CreateMessage();

            bm.AddPart(Guid.Empty.ToString(), BuildMessagePart(bmf, ComposeMessage(dvn), pc), true);

            // TODO: implement assembling logic

            // BizTalk 2004 documentation: "In this release of BizTalk Server 2004,

            // assembling functionality is not used, so BizTalk Server always passes

            // one document to the component input."

            return bm;

        }

private IBaseMessagePart BuildMessagePart(IBaseMessageFactory bmf, Stream s, IPipelineContext pc)

        {

            if (null == bmf || null == s)

                return null;

            IBaseMessagePart bmp = bmf.CreateMessagePart();

            bmp.Data = s;

            pc.ResourceTracker.AddResource(s);

            bmp.Data.Position = 0;

            return bmp;

        }