Hello,
I have a stateless session bean sending messages to a queue. I'd like the messages to be added at a rate of 40 per second to the queue. However my stateless session bean will not add to the queue until the previous message has been processed by the message driven bean. Here is the ejb queue connection code :
QueueConnectionFactory queueFactory =
(QueueConnectionFactory)context.lookup("ConnectionFactory");
// Create the connection
queueConnection = queueFactory.createQueueConnection();
// Create the session
queueSession = queueConnection.createQueueSession(
false, 0);
Here is my ejb-jar file :
<resource-ref>
<res-ref-name>jms/QueueFactory</res-ref-name>
<res-type>java:/XAConnectionFactory</res-type>
<res-auth>Container</res-auth>
</resource-ref>
and in my jboss.xml file I have :
<res-ref-name>jms/QueueFactory</res-ref-name>
<jndi-name>java:/XAConnectionFactory</jndi-name>
</resource-ref>
I am using jboss 2.4.3.
Has anyone any ideas as to where I am going wrong ?
Thanks,
Kenneth.