Hi, I want to improve the performance of the consumer and i went through couple of forum and found one of the suggestion to deal with prefetch size. however I am bit unsure about setting the value of this property for individual/all consumer because I am creating consumer for each message received. My code looks like:
Connection connection = connectionFactory.createConnection(); connection.start(); // Create a Session Session session = connection.createSession(true, -1); Queue queue = session.createQueue(queueName); // Create a MessageConsumer from the Session to the Topic or Queue MessageConsumer consumer = session.createConsumer(queue); The above code is inside in run method as I am using thread to consume message. So each thread would process a message with the above code. according to my requirement the processing should be within a transaction and hence I cannot afford to get two thread using either same session or consumer (and hence I need to create consumer for each message). I am not sure that in this case how would prefetch size can be set to increase the performance for message consuming process. Note: I am using XA transaction. any help. -- View this message in context: http://activemq.2283324.n4.nabble.com/consumer-too-slow-to-process-messages-tp4662235.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
