Repository: activemq-cpp Updated Branches: refs/heads/master 53dffc535 -> 6870af49a
https://issues.apache.org/jira/browse/AMQCPP-595 Use sync call to create a producer in order to capture exceptions from the broker on create Project: http://git-wip-us.apache.org/repos/asf/activemq-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-cpp/commit/6870af49 Tree: http://git-wip-us.apache.org/repos/asf/activemq-cpp/tree/6870af49 Diff: http://git-wip-us.apache.org/repos/asf/activemq-cpp/diff/6870af49 Branch: refs/heads/master Commit: 6870af49a91a5ec069c30f3a7b5d92d6ea4f735c Parents: 53dffc5 Author: Timothy Bish <[email protected]> Authored: Thu Mar 17 11:24:11 2016 -0400 Committer: Timothy Bish <[email protected]> Committed: Thu Mar 17 11:24:11 2016 -0400 ---------------------------------------------------------------------- .../src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-cpp/blob/6870af49/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp ---------------------------------------------------------------------- diff --git a/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp b/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp index f486964..a7cb9b6 100644 --- a/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp +++ b/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp @@ -686,7 +686,7 @@ cms::MessageProducer* ActiveMQSessionKernel::createProducer(const cms::Destinati try { this->addProducer(producer); - this->connection->oneway(producer->getProducerInfo()); + this->connection->syncRequest(producer->getProducerInfo()); } catch (Exception& ex) { this->removeProducer(producer); throw;
