summaryrefslogtreecommitdiff
path: root/qpid/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
commita0551acfe22a99433db840b246a56edb48f6f06e (patch)
tree8b14342b9ecd80716ffa4a2cb6502ebdeb2290b9 /qpid/java/client/src
parenta6a81a76243d18eee0022c37f5df30628e6df6e4 (diff)
downloadqpid-python-a0551acfe22a99433db840b246a56edb48f6f06e.tar.gz
changed for creating durable queue for a durable subscriber
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@629750 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src')
-rw-r--r--qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
index e2ae18a21f..9e7721310e 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
+++ b/qpid/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