You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2016/10/06 19:52:13 UTC
activemq git commit: NO-JIRA Add ability to set message reply-to for
in tests (cherry picked from commit 1316b57edba75336e02645abc3a7e8369526b2e8)
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 <ta...@gmail.com>
Authored: Thu Oct 6 15:51:31 2016 -0400
Committer: Timothy Bish <ta...@gmail.com>
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