Repository: activemq-cpp Updated Branches: refs/heads/3.9.x c54b43f41 -> a8b9e0346
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 (cherry picked from commit 6870af49a91a5ec069c30f3a7b5d92d6ea4f735c) Project: http://git-wip-us.apache.org/repos/asf/activemq-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-cpp/commit/a8b9e034 Tree: http://git-wip-us.apache.org/repos/asf/activemq-cpp/tree/a8b9e034 Diff: http://git-wip-us.apache.org/repos/asf/activemq-cpp/diff/a8b9e034 Branch: refs/heads/3.9.x Commit: a8b9e0346b68a17ff18f26e51195164015b8ac5a Parents: c54b43f Author: Timothy Bish <[email protected]> Authored: Thu Mar 17 11:24:11 2016 -0400 Committer: Timothy Bish <[email protected]> Committed: Thu Mar 17 11:31:05 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/a8b9e034/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;
