if (destination == null) {
log.info(this + " noticed that no reply-to destination has been set. Just returning");
</BUG>
return;
}
<BUG>final MessageProducer replyProducer = session.createProducer(destination);
final Message replyMsg = session.createTextMessage(Constants.REPLY_MESSAGE_PREFIX + ((TextMessage) message).getText());

replyMsg.setJMSCorrelationID(message.getJMSMessageID());
replyProducer.send(replyMsg);
replyProducer.close();
} catch (JMSException e) {</BUG>
throw new RuntimeException(e);

private LifecycleTracker lifeCycleTracker;
@Override
public void onMessage(Message message) {
try {
log.info(this + " received message " + message);
final Destination replyTo = message.getJMSReplyTo();
if (replyTo == null) {
log.info(this + " noticed that no reply-to replyTo has been set. Just returning");
return;
