summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2014-01-22 10:35:58 +0000
committerGordon Sim <gsim@apache.org>2014-01-22 10:35:58 +0000
commit8ad3d362d81ea08784930df2ba917a2532489929 (patch)
treee578c1fb45169887604b1a197cf8f9ec8013f765 /qpid/cpp/src
parentd5ffa452e824b9a8e18e48e527ae52b30fa901a1 (diff)
downloadqpid-python-8ad3d362d81ea08784930df2ba917a2532489929.tar.gz
QPID-5501: raise error if topic of given name already exists
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1560307 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/broker/amqp/Topic.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Topic.cpp b/qpid/cpp/src/qpid/broker/amqp/Topic.cpp
index 02a6f30104..7786180765 100644
--- a/qpid/cpp/src/qpid/broker/amqp/Topic.cpp
+++ b/qpid/cpp/src/qpid/broker/amqp/Topic.cpp
@@ -163,7 +163,7 @@ bool TopicRegistry::add(boost::shared_ptr<Topic> topic)
topics.insert(Topics::value_type(topic->getName(), topic));
return true;
} else {
- return false;
+ throw qpid::types::Exception(QPID_MSG("A topic named " << topic->getName() << " already exists"));
}
}