Polling on Mutliple MSMQs

[Vai2000]

Hi All, I have to poll on Multiple Queues for any inbound messages. I was
doing it fine earlier when there was only 1 Queue. I had added the
ReceiveComplete dEventHandler on the Queue and called the BeginReceive
method...
With multiple Queue's its a challenge...
I earlier implemented a logic provided by one of the forum users in which it
said to create an IAsyncResult Handle and then WaitHandle.Wait Any(array)...
but the Problem is when a new message arrives it doesn't notifies me....it
doesn't work the same as the EventHandler...

Here's the snippet I am using for Multiple Queues..its tied inside a WinSvc

protected override void OnStart(string[] args)
{

ThreadPool.Queu eUserWorkItem(n ew WaitCallback(Ex ecute));

}

void Execute(object key)
{

while(true)
{
aresMq1= mq1.BeginReceiv e();
aresMq2= mq2.BeginReceiv e();
Process();
}

}

void Process()
{

int iWaitIndex = WaitHandle.Wait Any(new
WaitHandle[]{aresMq1.AsyncW aitHandle, aresMq2.AsyncWa itHandle});

switch (iWaitIndex)
{

case 0:
Message msg1 = mq1.EndReceive( aresMq1);
Stream s1=PrepareMsg(m sg1,mq1);
writeMessage(s1 ,msg1.Label);
break;

case 1:
Message msg2 = mq2.EndReceive( aresMq2);
Stream s2=PrepareMsg(m sg2,mq2);
writeMessageEx( s2,msg2.Label);
break;

}
}

[Willy Denoyette [MVP]]

"Vai2000" <no****@microso ft.com> wrote in message
news:%2******** ********@TK2MSF TNGP10.phx.gbl. ..
| Hi All, I have to poll on Multiple Queues for any inbound messages. I was
| doing it fine earlier when there was only 1 Queue. I had added the
| ReceiveComplete dEventHandler on the Queue and called the BeginReceive
| method...
| With multiple Queue's its a challenge...
| I earlier implemented a logic provided by one of the forum users in which
it
| said to create an IAsyncResult Handle and then
WaitHandle.Wait Any(array)...
| but the Problem is when a new message arrives it doesn't notifies me....it
| doesn't work the same as the EventHandler...
|
| Here's the snippet I am using for Multiple Queues..its tied inside a
WinSvc
|
| protected override void OnStart(string[] args)
| {
|
| ThreadPool.Queu eUserWorkItem(n ew WaitCallback(Ex ecute));
|
| }
|
| void Execute(object key)
| {
|
| while(true)
| {
| aresMq1= mq1.BeginReceiv e();
| aresMq2= mq2.BeginReceiv e();
| Process();
| }
|
| }
|
| void Process()
| {
|
| int iWaitIndex = WaitHandle.Wait Any(new
| WaitHandle[]{aresMq1.AsyncW aitHandle, aresMq2.AsyncWa itHandle});
|
| switch (iWaitIndex)
| {
|
| case 0:
| Message msg1 = mq1.EndReceive( aresMq1);
| Stream s1=PrepareMsg(m sg1,mq1);
| writeMessage(s1 ,msg1.Label);
| break;
|
| case 1:
| Message msg2 = mq2.EndReceive( aresMq2);
| Stream s2=PrepareMsg(m sg2,mq2);
| writeMessageEx( s2,msg2.Label);
| break;
|
| }
| }
|
|

Why not simply create a thread per message queue, you don't have hundreds of
queue's I suppose?
Also, don't use the threadpool from OnStart, create a regular thread.

Willy.