I am facing a really bad performance of ActiveMq on linux box.
When running on windows 1000 transactions are taking 2 seconds and when
running on Linux same are taking 40 sec.
Please if anybody can tell me solution to performance issue.
Here is the code i am using to send and receive the message.
Thanks in advance
public class Requestor{
private Session session;
private Destination replyQueue;
private MessageProducer requestProducer;
private MessageConsumer replyConsumer;
Logger logger = null;
/**
* Constructor
*/
protected Requestor() {
super();
logger = LoggerWrapper.getLogger(this.getClass().getName());
}
/**
* This method will return the object of Requestor
* @param connection, Connection
* @param requestQueueName , String
* @return Requestor object
* @throws JMSException
* @throws NamingException
*/
public static Requestor newRequestor(Connection connection, String
requestQueueName)throws JMSException, NamingException {
Requestor requestor = new Requestor();
requestor.initialize(connection, requestQueueName);
return requestor;
}
/**
* This method will initialize the Producer and Consumer on request
and reply queue
* @param connection, Connection
* @param requestQueueName , String
* @throws NamingException
* @throws JMSException
*/
protected void initialize(Connection connection, String
requestQueueName)throws NamingException, JMSException {
session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Destination requestQueue =
session.createQueue(requestQueueName);
replyQueue = session.createTemporaryQueue();
requestProducer = session.createProducer(requestQueue);
requestProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
replyConsumer = session.createConsumer(replyQueue);
replyConsumer.receive(10);
}
/**
* This method is used to send the message to queue
* @param message
* @throws JMSException
*/
public String send(String message) throws JMSException {
TextMessage requestMessage = (TextMessage)
session.createTextMessage();
requestMessage.setText(message);
requestMessage.setJMSReplyTo(replyQueue);
requestProducer.send(requestMessage);
return receiveSync();
}
/**
* This method is used to receive the message from the queue
* @return String
* @throws JMSException
*/
private String receiveSync() throws JMSException {
TextMessage replyMessage = null;
Message msg = replyConsumer.receive();
if (msg instanceof TextMessage){
replyMessage = (TextMessage) msg;
}
logger.debug("receive Sync:"+ new Date().getTime());
return replyMessage.getText();
}
}
public class Replier implements MessageListener {
private Session session;
Logger logger = null;
Engine engineRef = null;
Transformer transformerRef = null;
MessageConsumer requestConsumer = null;
Destination replyDestination = null;
private static Map destinationMap = new HashMap();
/**
* Constructor
*
*/
protected Replier(){
super();
logger = LoggerWrapper.getLogger(this.getClass().getName());
}
/**
* This will return the instance of replier
* @param connection, Connection
* @param requestQueueName
* @return
* @throws Exception
*/
public static Replier newReplier(Connection connection,String
requestQueueName ,Engine engine,Transformer transformer)throws Exception {
Replier replier = new Replier();
replier.initialize(connection,
requestQueueName,engine,transformer);
return replier;
}
/**
* This method will initilize the consumer on request queue
* @param connection
* @param requestQueueName
* @throws Exception
*/
protected void initialize(Connection connection, String
requestQueueName, Engine engine,Transformer transformer)throws Exception {
session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
// Create the destination (Topic or Queue)
//Destination re
