public void sendMessage ( String requestMessage , String queueName , String correlationId , final Queue replyQueue , int delaySeconds , int deliveryMode ) throws JMSException { /** * If it's an internal message then always use jmsTemplate for ActiveMQ */ if ( jmsTemplate != null ) { jmsTemplate . setDeliveryMode ( deliveryMode ) ; if ( ! StringUtils . isEmpty ( queueName ) ) { jmsTemplate . send ( queueName , new MDWMessageCreator ( requestMessage , correlationId , replyQueue , delaySeconds ) ) ; } else { jmsTemplate . send ( new MDWMessageCreator ( requestMessage , correlationId , replyQueue ) ) ; } } }
Send a message to a queue with corrId delay and potential replyQueue