summaryrefslogtreecommitdiff
path: root/java/client/src
diff options
context:
space:
mode:
authorArnaud Simon <arnaudsimon@apache.org>2008-02-21 11:11:13 +0000
committerArnaud Simon <arnaudsimon@apache.org>2008-02-21 11:11:13 +0000
commite210317267eccbce31a25396f49f6c8688812f11 (patch)
tree40cf482516752da1693fed43773fa6a61d3d5a4b /java/client/src
parent0e76cde8c03200e9a3cc66f8db919429c0995941 (diff)
downloadqpid-python-e210317267eccbce31a25396f49f6c8688812f11.tar.gz
changed for creating durable queue for a durable subscriber
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629750 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/AMQTopic.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java b/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
index e2ae18a21f..9e7721310e 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
@@ -90,7 +90,7 @@ public class AMQTopic extends AMQDestination implements Topic
throws JMSException
{
return new AMQTopic(topic.getExchangeName(), ExchangeDefaults.TOPIC_EXCHANGE_CLASS, topic.getRoutingKey(), true, false,
- getDurableTopicQueueName(subscriptionName, connection), false);
+ getDurableTopicQueueName(subscriptionName, connection), true);
}
public static AMQShortString getDurableTopicQueueName(String subscriptionName, AMQConnection connection) throws JMSException