学步园

以下程序将创建一个名为MyApp的Biztalk应用程序，并为该程序添加一个MSMQ类型的接收端口和发送端口。接收端口将从"FORMATNAME:DIRECT=TCP:[FE80::F8F9:67DA:BCF7:7F35]/PRIVATE$/MQIn"处接收消息，然后将消息转发给发送端口。发送端口收到消息后，会将消息发送至FORMATNAME:DIRECT=TCP:[FE80::F8F9:67DA:BCF7:7F35]/PRIVATE$/MQOut"。

using System;<br /> using Microsoft.BizTalk.ExplorerOM;</p> <p>namespace ExplorerOMTest<br /> {<br /> class Program<br /> {<br /> static void Main(string[] args)<br /> {<br /> BtsCatalogExplorer catalog = null;<br /> try<br /> {<br /> // Connect BizTalk<br /> catalog = new BtsCatalogExplorer();<br /> catalog.ConnectionString = "Data Source=.;Initial Catalog=BizTalkMgmtDb;Integrated Security=SSPI;";</p> <p> // Create Application<br /> IBizTalkApplication application = catalog.AddNewApplication();<br /> application.Name = "MyApp";<br /> catalog.SaveChanges();</p> <p> // Create ReceivePort<br /> IReceivePort2 rp = application.AddNewReceivePort(false);<br /> rp.Name = "MyRP";<br /> IReceiveLocation2 rl = rp.AddNewReceiveLocation();<br /> rl.Name = "MyRL";<br /> rl.TransportType = catalog.ProtocolTypes["MSMQ"];<br /> rl.ReceivePipeline = catalog.Pipelines["Microsoft.BizTalk.DefaultPipelines.PassThruReceive"];<br /> rl.Address = @"FORMATNAME:DIRECT=TCP:[FE80::F8F9:67DA:BCF7:7F35]/PRIVATE$/MQIn"; // use IPv6<br /> rl.TransportTypeData = "<CustomProps><AdapterConfig vt=/"8/"><Config ><queue>" + rl.Address + "</queue><uri>" + rl.Address + "</uri><batchSize>20</batchSize><transactional>false</transactional><serialProcessing>false</serialProcessing><onFailure>suspendResumable</onFailure></Config></AdapterConfig></CustomProps>";</p> <p> // Create SendPort<br /> ISendPort2 sp = application.AddNewSendPort(false, false);<br /> sp.Name = "MySP";<br /> sp.PrimaryTransport.TransportType = catalog.ProtocolTypes["MSMQ"];<br /> sp.PrimaryTransport.Address = @"FORMATNAME:DIRECT=TCP:[FE80::F8F9:67DA:BCF7:7F35]/PRIVATE$/MQOut"; // use IPv6<br /> sp.PrimaryTransport.TransportTypeData = "<CustomProps><AdapterConfig vt=/"8/"><Config ><queue>" + sp.PrimaryTransport.Address + "</queue><uri>" + sp.PrimaryTransport.Address + "</uri><maximumMessageSize>1024</maximumMessageSize><acknowledgeType>None</acknowledgeType><timeOut>4</timeOut><priority>Normal</priority><recoverable>false</recoverable><encryptionAlgorithm>None</encryptionAlgorithm><useAuthentication>false</useAuthentication><segmentationSupport>false</segmentationSupport><transactional>false</transactional><useJournalQueue>false</useJournalQueue><useDeadLetterQueue>true</useDeadLetterQueue><ackTypeEnumsValue>0</ackTypeEnumsValue><timeOutUnits>Days</timeOutUnits><bodyType>8209</bodyType></Config></AdapterConfig></CustomProps>";<br /> sp.SendPipeline = catalog.Pipelines["Microsoft.BizTalk.DefaultPipelines.PassThruTransmit"];<br /> sp.Filter = "<Filter><Group><Statement Property=/"BTS.ReceivePortName/" Operator=/"0/" Value=/"" + rp.Name + "/" /></Group></Filter>";</p> <p> // Start BizTalk Application<br /> application.Start(ApplicationStartOption.StartAll);</p> <p> // Save changes<br /> catalog.SaveChanges();<br /> }<br /> catch (Exception ex)<br /> {<br /> // Cancel changes<br /> Console.WriteLine("Exception: " + ex.Message);<br /> if (catalog != null)<br /> catalog.DiscardChanges();<br /> }<br /> }<br /> }<br /> }<br />