commit | 6870af49a91a5ec069c30f3a7b5d92d6ea4f735c | [log] [tgz] |
---|---|---|
author | Timothy Bish <tabish121@gmail.com> | Thu Mar 17 11:24:11 2016 -0400 |
committer | Timothy Bish <tabish121@gmail.com> | Thu Mar 17 11:24:11 2016 -0400 |
tree | 7a508d35d5088cd96a7054ec652a432019f844c8 | |
parent | 53dffc535c0febcb49674e42f1a0067174fc3d95 [diff] |
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
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 @@ try { this->addProducer(producer); - this->connection->oneway(producer->getProducerInfo()); + this->connection->syncRequest(producer->getProducerInfo()); } catch (Exception& ex) { this->removeProducer(producer); throw;