I think you need to configure the prefetch size for the consumer - by
default - the prefetch limit would be less than 10000 for a queue
see: http://www.activemq.org/site/what-is-the-prefetch-limit-for.html
for some hints about increasing the prefetch limits for a consumer
On 2 Nov 2006, at 15:55, cwl999 wrote:
I'm writing an application that needs to produce at most 10000
messages for
every message consumed. This has to happen in a single
transaction. If I
use a non transacted session, everything works fine (but doesn't
meet the
requirements). If I set it to use a transacted session, the
connection
hangs after a while with the following errors
3081 [main] DEBUG org.apache.activemq.ActiveMQSession - Sending
message:
ActiveMQObjectMessage {commandId = 0, responseRequired = false,
messageId =
ID:07166HOBDGXP-4713-1162482684322-1:0:1:1:109, originalDestination
= null,
originalTransactionId = null, producerId =
ID:07166HOBDGXP-4713-1162482684322-1:0:1:1, destination = queue://
AWTX.TEST,
transactionId = TX:ID:07166HOBDGXP-4713-1162482684322-1:0:1,
expiration = 0,
timestamp = 1162482687730, arrival = 0, correlationId = null,
replyTo =
null, persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, compressed = false,
userID =
null, content = [EMAIL PROTECTED],
marshalledProperties = null, dataStructure = null,
redeliveryCounter = 0,
size = 0, properties = null, readOnlyProperties = true,
readOnlyBody = true}
15001 [ActiveMQ Scheduler] DEBUG
org.apache.activemq.transport.InactivityMonitor - A send is in
progress
29956 [ActiveMQ Scheduler] DEBUG
org.apache.activemq.transport.InactivityMonitor - A send is in
progress
30003 [ActiveMQ Scheduler] DEBUG
org.apache.activemq.transport.InactivityMonitor - Message received
since
last read check, resetting flag:
I've written a test prog to demo this
import java.io.Serializable;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.log4j.BasicConfigurator;
import org.apache.log4j.Logger;
public class Main implements Serializable
{
static private Logger logger = Logger.getLogger(Main.class);
byte[] dummy = new byte[100000];
/**
* @param args
*/
public static void main(String[] args)
{
BasicConfigurator.configure();
try
{
ActiveMQConnectionFactory factory = new
ActiveMQConnectionFactory(
"tcp://localhost:61616");
Connection connection;
connection = factory.createConnection();
Session session = connection.createSession(true,
Session.SESSION_TRANSACTED);
MessageProducer producer =
session.createProducer(session.createQueue("AWTX.TEST"));
for (int i = 0; i < 1000; i++)
{
System.out.println(i);
ObjectMessage objectMessage = session.createObjectMessage(new
Main());
producer.send(objectMessage);
}
producer.close();
session.commit();
session.close();
connection.close();
}
catch (JMSException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
--
View this message in context: http://www.nabble.com/Hanging-on-big-
transacted-sessions-tf2560589.html#a7136242
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
