Repository: activemq Updated Branches: refs/heads/activemq-5.14.x 70432bf31 -> 37c20ed19
NO-JIRA Add ability to set message reply-to for in tests (cherry picked from commit 1316b57edba75336e02645abc3a7e8369526b2e8) Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/37c20ed1 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/37c20ed1 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/37c20ed1 Branch: refs/heads/activemq-5.14.x Commit: 37c20ed19ff104811ff6b9e5f6d458b9b89ae490 Parents: 70432bf Author: Timothy Bish <[email protected]> Authored: Thu Oct 6 15:51:31 2016 -0400 Committer: Timothy Bish <[email protected]> Committed: Thu Oct 6 15:52:04 2016 -0400 ---------------------------------------------------------------------- .../transport/amqp/client/AmqpMessage.java | 25 ++++++++++++++++++++ 1 file changed, 25 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/37c20ed1/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/client/AmqpMessage.java ---------------------------------------------------------------------- diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/client/AmqpMessage.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/client/AmqpMessage.java index e5e1bbd..952f98d 100644 --- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/client/AmqpMessage.java +++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/client/AmqpMessage.java @@ -239,6 +239,31 @@ public class AmqpMessage { } /** + * Sets the address which is applied to the AMQP message ReplyTo field in the message properties + * + * @param replyTo + * The address that should be applied in the Message ReplyTo field. + */ + public void setReplyTo(String replyTo) { + checkReadOnly(); + lazyCreateProperties(); + getWrappedMessage().setReplyTo(replyTo); + } + + /** + * Return the set address that was set in the Message ReplyTo field. + * + * @return the set address String form or null if not set. + */ + public String getReplyTo() { + if (message.getProperties() == null) { + return null; + } + + return message.getProperties().getReplyTo(); + } + + /** * Sets the MessageId property on an outbound message using the provided String * * @param messageId
