Author: arnaudsimon
Date: Thu Feb 21 03:11:13 2008
New Revision: 629750
URL: http://svn.apache.org/viewvc?rev=629750&view=rev
Log:
changed for creating durable queue for a durable subscriber
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java?rev=629750&r1=629749&r2=629750&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java
Thu Feb 21 03:11:13 2008
@@ -90,7 +90,7 @@
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
