code: @Override
      public Message createMessage(Session session) throws JMSException {
          Message message = session.createTextMessage(requestMessage);
          if (correlationId != null)
              message.setJMSCorrelationID(correlationId);
          if (replyQueue != null) {
              message.setJMSReplyTo(replyQueue);
          }
          if (delaySeconds >0) {
              ApplicationContext.getJmsProvider().setMessageDelay(null, message, delaySeconds);
          }
          return message;
      }
docs: /*
  (non-Javadoc)
  
  @see
  org.springframework.jms.core.MessageCreator#createMessage(javax.jms
  .Session)