From edc65efef91c7073b3caa8190184b6e3a6f756a4 Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Wed, 11 May 2011 21:43:58 +0000
Subject: QPID-3254 Added a check to ensure that durable subscriptions are only
 created for Topics. Added code to mark a destination durable. If the
 addressing string explicitly specified durable==false, it will be overriden.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1102102 13f79535-47bb-0310-9956-ffa450edef68
---
 java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 5 +++++
 1 file changed, 5 insertions(+)

(limited to 'java/client/src')

diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
index f85b1e655d..25562cfff7 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
@@ -1058,6 +1058,11 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic
             try
             {
                 handleAddressBasedDestination(dest,false,true);
+                if (dest.getAddressType() !=  AMQDestination.TOPIC_TYPE)
+                {
+                    throw new JMSException("Durable subscribers can only be created for Topics");
+                }
+                dest.getSourceNode().setDurable(true);
             }
             catch(AMQException e)
             {
-- 
cgit v1.2.1