keenan
08-29-2008, 04:08 PM
Hopefully someone can set me straight here because I'm having a lot of issues with queueing and I'm starting to think maybe I'm missing some fundamentals.
I have a producer which puts 50000 messages on a queue:
while (count < 50000)
{
count++;
string text = "message # " + count.ToString();
NmsTemplate.ConvertAndSend("step.1", text);
}
In my configuration I have a listener container which has a chain of listeners that simply copies a message from one queue to another:
<object id="echoHandler" type="MyMessageDemo.Test3.Echo, MyMessageDemo"/>
<nms:listener-container acknowledge="client" concurrency="20" connection-factory="mqConnFactory">
<nms:listener destination="step.1" ref="echoHandler" method="Receive" response-destination="step.2"/>
<nms:listener destination="step.2" ref="echoHandler" method="Receive" response-destination="step.3"/>
<nms:listener destination="step.3" ref="echoHandler" method="Receive" response-destination="step.4"/>
<nms:listener destination="step.4" ref="echoHandler" method="Receive" response-destination="step.5"/>
<nms:listener destination="step.5" ref="echoHandler" method="Receive" response-destination="step.6"/>
</nms:listener-container>
The Echo class is simply:
class Echo
{
public string Receive(string message)
{
Thread.Sleep(50);
return message;
}
}
When I run the program, various errors occur, such as:
Error: : Collection was modified; enumeration operation may not execute.
or, sometimes the program crashes. Other times it gets stuck because listeners get unregistered and I end up with 0 listeners on some of the queues and > 20 listeners (the concurrency value) on the others.
Here is my connection factory:
<object id="mqConnFactoryNoCache" type="Apache.NMS.ActiveMQ.ConnectionFactory, Apache.NMS.ActiveMQ">
<constructor-arg index="0" value="tcp://localhost:61616?jms.prefetchPolicy.all=100&transpo rt.requesttimeout=15000"/>
</object>
<object id="mqConnFactory" type="Spring.Messaging.Nms.Connections.SingleConnectionF actory, Spring.Messaging.Nms">
<constructor-arg name="targetConnectionFactory" ref="mqConnFactoryNoCache"/>
<property name="ReconnectOnException" value="true"/>
</object>
Surely I'm missing something basic here?
I have a producer which puts 50000 messages on a queue:
while (count < 50000)
{
count++;
string text = "message # " + count.ToString();
NmsTemplate.ConvertAndSend("step.1", text);
}
In my configuration I have a listener container which has a chain of listeners that simply copies a message from one queue to another:
<object id="echoHandler" type="MyMessageDemo.Test3.Echo, MyMessageDemo"/>
<nms:listener-container acknowledge="client" concurrency="20" connection-factory="mqConnFactory">
<nms:listener destination="step.1" ref="echoHandler" method="Receive" response-destination="step.2"/>
<nms:listener destination="step.2" ref="echoHandler" method="Receive" response-destination="step.3"/>
<nms:listener destination="step.3" ref="echoHandler" method="Receive" response-destination="step.4"/>
<nms:listener destination="step.4" ref="echoHandler" method="Receive" response-destination="step.5"/>
<nms:listener destination="step.5" ref="echoHandler" method="Receive" response-destination="step.6"/>
</nms:listener-container>
The Echo class is simply:
class Echo
{
public string Receive(string message)
{
Thread.Sleep(50);
return message;
}
}
When I run the program, various errors occur, such as:
Error: : Collection was modified; enumeration operation may not execute.
or, sometimes the program crashes. Other times it gets stuck because listeners get unregistered and I end up with 0 listeners on some of the queues and > 20 listeners (the concurrency value) on the others.
Here is my connection factory:
<object id="mqConnFactoryNoCache" type="Apache.NMS.ActiveMQ.ConnectionFactory, Apache.NMS.ActiveMQ">
<constructor-arg index="0" value="tcp://localhost:61616?jms.prefetchPolicy.all=100&transpo rt.requesttimeout=15000"/>
</object>
<object id="mqConnFactory" type="Spring.Messaging.Nms.Connections.SingleConnectionF actory, Spring.Messaging.Nms">
<constructor-arg name="targetConnectionFactory" ref="mqConnFactoryNoCache"/>
<property name="ReconnectOnException" value="true"/>
</object>
Surely I'm missing something basic here?