summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArnaud Simon <arnaudsimon@apache.org>2007-10-18 15:02:15 +0000
committerArnaud Simon <arnaudsimon@apache.org>2007-10-18 15:02:15 +0000
commit0b39a6d14d796a7b8aeb160f9bdf0f92e2bd07ab (patch)
tree576002fb261eee7db51bfdb883c860eff85b5137
parent7f325f32bf02007add378df60c50c554f37567af (diff)
downloadqpid-python-0b39a6d14d796a7b8aeb160f9bdf0f92e2bd07ab.tar.gz
changed to set delivery mode of received message
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585997 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java
index 0df4661b25..083912d8ac 100644
--- a/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java
+++ b/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java
@@ -131,7 +131,8 @@ public abstract class AbstractJMSMessageFactory implements MessageFactory
{
props.setEncoding(encoding);
}
- props.setExpiration(devprop.getExpiration());
+ props.setDeliveryMode((byte) devprop.getDeliveryMode());
+ props.setExpiration(devprop.getExpiration());
props.setMessageId(mprop.getMessageId());
props.setPriority((byte) devprop.getPriority());
props.setReplyTo(replyToURL);