<?xml version="1.0" encoding="UTF-8" ?>
<?xml-stylesheet type="text/xsl" href="http://blogs.msdn.com/utility/FeedStylesheets/rss.xsl" media="screen"?><rss version="2.0" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:slash="http://purl.org/rss/1.0/modules/slash/" xmlns:wfw="http://wellformedweb.org/CommentAPI/"><channel><title>Integration - Bridging Microsoft MSMQ and IBM WebSphere MQ on 64-bit Windows</title><link>http://blogs.msdn.com/johnbreakwell/archive/2008/03/10/integration-bridging-microsoft-msmq-and-ibm-websphere-mq-on-64-bit-windows.aspx</link><description>The MSMQ-MQSeries Bridge , which ships with Host Integration Server 2006 (HIS 2006) and earlier, is a well-established way to integrate the messaging worlds of Microsoft and IBM. The Bridge is essentially a Windows application written to use the MQSeries</description><dc:language>en-GB</dc:language><generator>CommunityServer 2.1 SP1 (Build: 61025.2)</generator><item><title>re: Integration - Bridging Microsoft MSMQ and IBM WebSphere MQ on 64-bit Windows</title><link>http://blogs.msdn.com/johnbreakwell/archive/2008/03/10/integration-bridging-microsoft-msmq-and-ibm-websphere-mq-on-64-bit-windows.aspx#8350686</link><pubDate>Wed, 02 Apr 2008 13:30:24 GMT</pubDate><guid isPermaLink="false">91d46819-8472-40ad-a661-2c78acb4018c:8350686</guid><dc:creator>Jimmy</dc:creator><description>&lt;p&gt;Hi, Hope to get help from you.&lt;/p&gt;
&lt;p&gt;We implement a messaging systems. The server receives message from clients and stores it in MSMQ. It then forward the message to another destination. The program of routing message first enable the MSMQ: MQAutoReceive(q2)&lt;/p&gt;
&lt;p&gt;MQAutoReceive (MessageQueue objQName, //) {...//&lt;/p&gt;
&lt;p&gt;//......&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;objQName = new MessageQueue(&amp;quot;.\\Private$\\&amp;quot; + qNameToPtTo);&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;objQName.Formatter = new XmlMessageFormatter(new Type[] { typeof(byte[]) });&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;objQName.ReceiveCompleted += new ReceiveCompletedEventHandler(nameOfHandler);&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;objQName.UseJournalQueue = useJournal;&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;objQName.MessageReadPropertyFilter.ArrivedTime = true;&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;objQName.BeginReceive();&lt;/p&gt;
&lt;p&gt;//......}&lt;/p&gt;
&lt;p&gt;The handler of completed message receiving like this:&lt;/p&gt;
&lt;p&gt;q2ReceiveCompleted(object p_source, ReceiveCompletedEventArgs p_objAsyncResult)&lt;/p&gt;
&lt;p&gt;{&lt;/p&gt;
&lt;p&gt;//..........&lt;/p&gt;
&lt;p&gt;try{&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;q2 = ((MessageQueue)(p_source));&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;m2 = q2.EndReceive(p_objAsyncResult.AsyncResult);&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;if (m2.ArrivedTime.AddSeconds(msgValidity) &amp;lt; DateTime.Now)&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;{&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;q2.Refresh();&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;q2.BeginReceive();&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;return;&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;}&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;m2.TimeToReachQueue = new TimeSpan(0, 0, TIME_TO_REACH_Q);&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;m2.AdministrationQueue = q2AdminQ;&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;m2.AcknowledgeType = AcknowledgeTypes.FullReachQueue;&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;m2.UseJournalQueue = true; &amp;nbsp; &amp;nbsp;&lt;/p&gt;
&lt;p&gt;//.........................&lt;/p&gt;
&lt;p&gt; &amp;nbsp;}&lt;/p&gt;
&lt;p&gt;catch {&lt;/p&gt;
&lt;p&gt;}&lt;/p&gt;
&lt;p&gt;finally {&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;q2.Refresh();&lt;/p&gt;
&lt;p&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;q2.BeginReceive();&lt;/p&gt;
&lt;p&gt;}&lt;/p&gt;
&lt;p&gt;We have very serious problem of memory leaking. We dont really comprehend it as the message in queue is removed (EndReceive), but still memory is growing.&lt;/p&gt;
&lt;p&gt;Hope to get help from you.&lt;/p&gt;
&lt;p&gt;Thank you.&lt;/p&gt;</description></item><item><title>re: Integration - Bridging Microsoft MSMQ and IBM WebSphere MQ on 64-bit Windows</title><link>http://blogs.msdn.com/johnbreakwell/archive/2008/03/10/integration-bridging-microsoft-msmq-and-ibm-websphere-mq-on-64-bit-windows.aspx#8932949</link><pubDate>Mon, 08 Sep 2008 14:46:56 GMT</pubDate><guid isPermaLink="false">91d46819-8472-40ad-a661-2c78acb4018c:8932949</guid><dc:creator>JohnBrea</dc:creator><description>&lt;p&gt;Hi Jimmy,&lt;/p&gt;
&lt;p&gt;I regret to say that this one slipped through the net and I've only just found it - non-anonymous comments are automatically accepted.&lt;/p&gt;
&lt;p&gt;Did you get to the bottom of the problem?&lt;/p&gt;
&lt;p&gt;Cheers&lt;/p&gt;
&lt;p&gt;John Breakwell&lt;/p&gt;
</description></item></channel></rss>