You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2013/09/09 19:08:30 UTC
svn commit: r1521191 - in /qpid/trunk/qpid/cpp/src/qpid/broker:
SemanticState.cpp SessionAdapter.cpp
Author: aconway
Date: Mon Sep 9 17:08:30 2013
New Revision: 1521191
URL: http://svn.apache.org/r1521191
Log:
QPID-4327: HA support for TX transactions - consistent use of QueueRegistry::get
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp
qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp?rev=1521191&r1=1521190&r2=1521191&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp Mon Sep 9 17:08:30 2013
@@ -665,9 +665,7 @@ Queue::shared_ptr SemanticState::getQueu
if (name.empty()) {
throw NotAllowedException(QPID_MSG("No queue name specified."));
} else {
- queue = session.getBroker().getQueues().find(name);
- if (!queue)
- throw NotFoundException(QPID_MSG("Queue not found: "<<name));
+ queue = session.getBroker().getQueues().get(name);
}
return queue;
}
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp?rev=1521191&r1=1521190&r2=1521191&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/SessionAdapter.cpp Mon Sep 9 17:08:30 2013
@@ -685,9 +685,7 @@ Queue::shared_ptr SessionAdapter::Handle
if (name.empty()) {
throw framing::IllegalArgumentException(QPID_MSG("No queue name specified."));
} else {
- queue = session.getBroker().getQueues().find(name);
- if (!queue)
- throw framing::NotFoundException(QPID_MSG("Queue not found: "<<name));
+ queue = session.getBroker().getQueues().get(name);
}
return queue;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org