public void processAndReplyWithSendTo() throws Exception {
MessagingMessageListenerAdapter listener = createDefaultInstance(String.class);
String body = "echo text";
String messageId = "msgId-1234";
MessageProperties properties = new MessageProperties();
properties.setMessageId(messageId);
org.springframework.amqp.core.Message message = createTextMessage(body, properties);
// MessageId is used as fallback when no correlationId is set
processAndReply(listener, message, "replyDestination", "", false, messageId);
assertDefaultListenerMethodInvocation();