activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject activemq-cpp git commit: https://issues.apache.org/jira/browse/AMQCPP-595
Date Thu, 17 Mar 2016 15:31:11 GMT
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 <tabish121@gmail.com>
Authored: Thu Mar 17 11:24:11 2016 -0400
Committer: Timothy Bish <tabish121@gmail.com>
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;


Mime
View raw message