Sample below...
A few thoughts/comments - first, I think you always want to EndPeek. I
remember reading somewhere that the API docs state that the framework does
not promise to behave nicely if you forget to. Second, EndPeek will throw an
exception if BeginPeek times out. I added the 'using' statements on the
messages because they are disposable and I am a little superstitutious about
that more than that I have ever actually seen that cause a problem. It would
seem weird to me that a Message object would actually hold on to some
important unmanaged resource, but who knows? Reflector doesn't make it
obvious. Maybe someone can comment on that. FWIW, I highly recommend you set
up a little functional test in NUnit or whatever it is you use to write your
tests to simulate the situation you are looking for and prove it out to
yourself. You don't even have to have Navision running. There are few things
like the comfort of a good, green bar to aid in understanding.
I hope that helps!
Thanks,
Jef Newsom
private void ReceiveQ_PeekCompleted(object sender, PeekCompletedEventArgs e)
{
try
{
MessageQueue messageQueue = sender as MessageQueue;
using(Message message = messageQueue.EndPeek(e.AsyncResult))
{
if(!message.CorrelationId.Equals(_correlationId))
{
messageQueue.BeginPeek(_timeOut);
return;
}
}
using(message = messageQueue.ReceiveByCorrelationId(_correlationId))
{
// do something with it.
}
}
catch(MessageQueueException e)
{
if(e.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout*)*
* {*
// log it, peek again, whatever you think is the right thing to do.
}
}
}
On 8/5/06, Paul Cowan <[EMAIL PROTECTED]> wrote:
Hi,
THe eventargs contains the message. I have the following event handler
for PeekCompleted:
private void ReceiveQ_PeekCompleted(object sender, PeekCompletedEventArgs
e)
{
if (e.Message.CorrelationId != _correlationId)
{
messageQueue.BeginPeek(_timeOut);
return;
}
MessageQueue messageQueue = sender as MessageQueue;
Message message = messageQueue.EndPeek(e.AsyncResult);
}
My question is what if there is an error on the other side and the message
never gets placed onto the queue?? How can I timeout gracefully if
BeginPeek is being called each time?
Thanks
Paul
[EMAIL PROTECTED]
> Date: Sat, 5 Aug 2006 14:16:28 -0500> From: [EMAIL PROTECTED]>
Subject: Re: [ADVANCED-DOTNET] ReceiveByCorrelationId + MSMQ> To:
[email protected]> > I think you can just do a BeginPeek
and check the correlationId against the> message you receive from the
EndPeek. If it is [one of your outstanding]> message[s], then
receiveByCorrelationId. If not, then ignore and BeginPeek> again. Sorry, I
haven't worked with MSMQ in over a year, so the details are> a bit rusty,
but I think that should work for you.> > On 8/5/06, Paul Cowan <
[EMAIL PROTECTED]> wrote:> >> > Hi,> >> > We are creating a web
application that unfortunately has to communicate> > with a product called
Navision. The communication is to send and receive> > xml documents via
MSMQ.> > The process is we send a message to one queue and receive messages
on> > another queue. The only reliable way I have been able to marry these>
> messages together is to by setting the CorrelationId of the response
message> > to be the id of the request message.So far I am doing this
synchronously> > using the ReceiveByCorrelationId method. I have grave
worries of how this> > will scale and I don't think it is thread safe.> >> >
My code is as follows:> >> > while ( receiveQ.PeekByCorrelationId(messageId,
_timeOut) != null)> > {> > message =
receiveQ.ReceiveByCorrelationId(messageId,
_timeOut);> > }> >> > I would like to do this asynchronously but am really
not sure how to go> > about this.> >> > Can anyone with MSMQ experience tell
me how I can accomplish this problem> > asynchronously??> > Thanks> > Paul>
>> >> > ===================================> > This list is hosted by
DevelopMentor(r) http://www.develop.com> >> > View archives and manage
your subscription(s) at> > http://discuss.develop.com> >> >
===================================> This list is hosted by DevelopMentor(r)
http://www.develop.com> > View archives and manage your subscription(s) at
http://discuss.develop.com
===================================
This list is hosted by DevelopMentor(r) http://www.develop.com
View archives and manage your subscription(s) at http://discuss.develop.com
===================================
This list is hosted by DevelopMentor® http://www.develop.com
View archives and manage your subscription(s) at http://discuss.develop.com
