You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2014/01/22 11:35:58 UTC
svn commit: r1560307 - /qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Topic.cpp
Author: gsim
Date: Wed Jan 22 10:35:58 2014
New Revision: 1560307
URL: http://svn.apache.org/r1560307
Log:
QPID-5501: raise error if topic of given name already exists
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Topic.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Topic.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Topic.cpp?rev=1560307&r1=1560306&r2=1560307&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Topic.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/amqp/Topic.cpp Wed Jan 22 10:35:58 2014
@@ -163,7 +163,7 @@ bool TopicRegistry::add(boost::shared_pt
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"));
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org