diff options
| -rw-r--r-- | qpid/wcf/test/Apache/Qpid/Test/Channel/WcfPerftest/WcfPerftest.cs | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/qpid/wcf/test/Apache/Qpid/Test/Channel/WcfPerftest/WcfPerftest.cs b/qpid/wcf/test/Apache/Qpid/Test/Channel/WcfPerftest/WcfPerftest.cs index 413c185039..c97d3da27c 100644 --- a/qpid/wcf/test/Apache/Qpid/Test/Channel/WcfPerftest/WcfPerftest.cs +++ b/qpid/wcf/test/Apache/Qpid/Test/Channel/WcfPerftest/WcfPerftest.cs @@ -391,8 +391,13 @@ namespace Apache.Qpid.Test.Channel.WcfPerftest Console.WriteLine("Initializing transactions");
IRawBodyUtility bodyUtil = new RawEncoderUtility();
- // send a transacted message to nowhere to force the initial registration with MSDTC
- IOutputChannel channel = QueueChannelFactory.CreateWriterChannel("", Guid.NewGuid().ToString());
+ // Send a transacted message to nowhere to force the initial registration with MSDTC.
+ // MSDTC insists on verifying it can contact the resource in the manner expected for
+ // recovery. This requires setting up and finishing a separate connection to the
+ // broker by a thread owned by the DTC. Excluding this time allows the existing
+ // reporting mechanisms to better reflect the cost per transaction without requiring
+ // long test runs.
+ IOutputChannel channel = QueueChannelFactory.CreateWriterChannel("amq.direct", Guid.NewGuid().ToString());
Message msg = bodyUtil.CreateMessage("sacrificial transacted message from WcfPerftest");
using (TransactionScope ts = new TransactionScope())
{
|