[jboss-user] [JBoss Messaging] - Sending a message to a queue is slow sometimes.
Hi,
I am experiencing periodic performance issues when sending an object to a message queue on
jboss 5 jmessaging.
Normally this operation takes 10 ms but sometimes(1%) I see 5+ seconds below is the code.
I have ruled out Garbage collection as the cause. Any advice on the code below
specifically on the message send line and why it would be a resource problem - any queue
sizing I need to be aware of?
I use mysql as the persistence layer to a localhost database - any connection pool sizing
I should be aware of ( I use a connection pool of min 5 / max 20 ).
Any advice on performance please ?
Thanks,
Colm
public final static void sendObjectToQueue(String queueName,
| EPOSBatchMessage messageObject) {
| long startTime = System.currentTimeMillis();
| QueueConnection conn = null;
| QueueSession session = null;
| Queue que = null;
| InitialContext iniCtx = null;
| QueueConnectionFactory qcf = null;
| Object tmp = null;
| QueueSender send = null;
| try {
| log.debug("PERFORMANCE: (sendObjectToQueue): size of message: " +
messageObject.toString().length() + " - " + (System.currentTimeMillis() -
startTime ) + "(ms)");
|
| iniCtx = new InitialContext();
| tmp = iniCtx.lookup("ConnectionFactory");
| qcf = (QueueConnectionFactory) tmp;
| log.debug("PERFORMANCE: (sendObjectToQueue): About to create connection:
" + (System.currentTimeMillis() - startTime ) + "(ms)");
| conn = qcf.createQueueConnection();
| log.debug("PERFORMANCE: (sendObjectToQueue): Connection Created: " +
(System.currentTimeMillis() - startTime ) + "(ms)");
| que = (Queue) iniCtx.lookup(queueName);
| log.debug("PERFORMANCE: (sendObjectToQueue): Queue lookup succeeded: " +
(System.currentTimeMillis() - startTime ) + "(ms)");
| session = conn.createQueueSession(false,
| QueueSession.AUTO_ACKNOWLEDGE);
| log.debug("PERFORMANCE: (sendObjectToQueue): Session Created: " +
(System.currentTimeMillis() - startTime ) + "(ms)");
| send = session.createSender(que);
| log.debug("PERFORMANCE: (sendObjectToQueue): Sender Created: " +
(System.currentTimeMillis() - startTime ) + "(ms)");
| ObjectMessage om = session.createObjectMessage();
| om.setObject(messageObject);
| log.debug("PERFORMANCE: (sendObjectToQueue): Message Created: " +
(System.currentTimeMillis() - startTime ) + "(ms)");
| send.send(om); // <----- this is where the slow down is occuring
| log.debug("PERFORMANCE: (sendObjectToQueue): Message Sent: " +
(System.currentTimeMillis() - startTime ) + "(ms)");
| log.info("sendMessage, sent object = " + om
| + " sent queue = " + queueName);
| if(send!=null){ send.close(); }
| if(conn!=null){conn.close();}
| if(session!=null){session.close();}
| }catch (Exception e){
| log.error("In sendObjectToQueue: caught exception: " + e);
| e.printStackTrace();
| }
| long endTime = System.currentTimeMillis();
| long time = endTime - startTime;
| log.debug("PERFORMANCE: (sendObjectToQueue" + queueName + " , "
+ messageObject + "): Time Taken: " + time + "(ms)");
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4226728#...
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...