commit | a8b9e0346b68a17ff18f26e51195164015b8ac5a | [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:31:05 2016 -0400 |
tree | 32f52c0fe749e5bec942117bc7c98e66b8569702 | |
parent | c54b43f4175764458931a74162c647d5b7be31e0 [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 (cherry picked from commit 6870af49a91a5ec069c30f3a7b5d92d6ea4f735c)
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;