Thread 3 (Thread 0x7f3f45341700 (LWP 30627)):
#0 0x00007f4548f63a35 in pthread_cond_wait@@GLIBC_2.3.2 () from /lib64/libpthread.so.0
#1 0x00007f454943baec in std::condition_variable::wait(std::unique_lock<std::mutex>&) () from /lib64/libstdc++.so.6
#2 0x0000000000c5f423 in pulsar::Future<bool, pulsar::Result>::get (this=this@entry=0x7f3f4533d700, result=@0x7f3f4533d6f0: pulsar::ResultOk) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/Future.h:70
#3 0x0000000000cbc438 in pulsar::Producer::close (this=0xd0f6ef0) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/Producer.cc:82
#4 0x0000000000b2b2de in PulsarProducerObject::~PulsarProducerObject (this=0xd12c810, __in_chrg=<optimized out>) at source/gse-data/server_data/exporter/pulsar/pulsar_producer.h:74
#5 0x0000000000b2a296 in PulsarProducer::handleSendCallback (result=pulsar_result_Ok, msgId=0xd0f79a0, ctx=0xd12c810) at source/gse-data/server_data/exporter/pulsar/pulsar_producer.cpp:169
#6 0x0000000000c2586d in __call<void, pulsar::Result&&, const pulsar::MessageId&, 0ul, 1ul, 2ul, 3ul> (__args=<optimized out>, this=<optimized out>) at /usr/include/c++/4.8.2/functional:1296
#7 operator()<pulsar::Result, const pulsar::MessageId&, void> (this=<optimized out>) at /usr/include/c++/4.8.2/functional:1355
#8 std::_Function_handler<void (pulsar::Result, pulsar::MessageId const&), std::_Bind<void (*(std::_Placeholder<1>, std::_Placeholder<2>, void (*)(pulsar_result, _pulsar_message_id*, void*), void*))(pulsar::Result, pulsar::MessageId, void (*)(pulsar_result, _pulsar_message_id*, void*), void*)> >::_M_invoke(std::_Any_data const&, pulsar::Result, pulsar::MessageId const&) (__functor=..., __args#0=<optimized out>, __args#1=...) at /usr/include/c++/4.8.2/functional:2071
#9 0x0000000000d6b0a9 in operator() (__args#1=..., __args#0=pulsar::ResultOk, this=<optimized out>) at /usr/include/c++/4.8.2/functional:2471
#10 pulsar::completeSendCallbacks(const std::vector<std::function<void(pulsar::Result, const pulsar::MessageId&)>, std::allocator<std::function<void(pulsar::Result, const pulsar::MessageId&)> > > &, pulsar::Result, const pulsar::MessageId &) (callbacks=std::vector of length 1, capacity 1 = {...}, result=pulsar::ResultOk, id=...) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/MessageAndCallbackBatch.cc:57
#11 0x0000000000cc1313 in complete (messageId=..., result=pulsar::ResultOk, this=0x7f3f4533dbd0) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/OpSendMsg.h:58
#12 pulsar::ProducerImpl::ackReceived (this=0xd3f0018, sequenceId=sequenceId@entry=0, rawMessageId=...) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/ProducerImpl.cc:834
#13 0x0000000000d3af27 in pulsar::ClientConnection::handleIncomingCommand (this=this@entry=0xd3fb000) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/ClientConnection.cc:833
#14 0x0000000000d413da in pulsar::ClientConnection::processIncomingBuffer (this=this@entry=0xd3fb000) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/ClientConnection.cc:686
#15 0x0000000000d41ef8 in pulsar::ClientConnection::handleRead (this=0xd3fb000, err=..., bytesTransferred=<optimized out>, minReadSize=4) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/ClientConnection.cc:610
#16 0x0000000000d30cc8 in _M_call<std::shared_ptr<pulsar::ClientConnection>&, boost::system::error_code&, unsigned long&, unsigned int&> (__ptr=..., this=<optimized out>) at /usr/include/c++/4.8.2/functional:558
#17 operator()<std::shared_ptr<pulsar::ClientConnection>&, boost::system::error_code&, long unsigned int&, unsigned int&, void> (__object=..., this=<optimized out>) at /usr/include/c++/4.8.2/functional:610
#18 __call<void, boost::system::error_code&, unsigned long&, 0ul, 1ul, 2ul, 3ul> (__args=<optimized out>, this=<optimized out>) at /usr/include/c++/4.8.2/functional:1296
#19 operator()<boost::system::error_code&, long unsigned int&, void> (this=<optimized out>) at /usr/include/c++/4.8.2/functional:1355
#20 operator()<boost::system::error_code, long unsigned int> (arg2=<optimized out>, arg1=..., this=<optimized out>) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/UtilAllocator.h:63
#21 operator() (this=<optimized out>) at /usr/local/include/boost/asio/detail/bind_handler.hpp:127
#22 asio_handler_invoke<boost::asio::detail::binder2<AllocHandler<std::_Bind<std::_Mem_fn<void (pulsar::ClientConnection::*)(const boost::system::error_code&, long unsigned int, unsigned int)>(std::shared_ptr<pulsar::ClientConnection>, std::_Placeholder<1>, std::_Placeholder<2>, unsigned int)> >, boost::system::error_code, long unsigned int> > (function=...) at /usr/local/include/boost/asio/handler_invoke_hook.hpp:64
#23 boost_asio_handler_invoke_helpers::invoke<boost::asio::detail::binder2<AllocHandler<std::_Bind<std::_Mem_fn<void (pulsar::ClientConnection::*)(const boost::system::error_code&, long unsigned int, unsigned int)>(std::shared_ptr<pulsar::ClientConnection>, std::_Placeholder<1>, std::_Placeholder<2>, unsigned int)> >, boost::system::error_code, long unsigned int>, AllocHandler<std::_Bind<std::_Mem_fn<void (pulsar::ClientConnection::*)(const boost::system::error_code&, long unsigned int, unsigned int)>(std::shared_ptr<pulsar::ClientConnection>, std::_Placeholder<1>, std::_Placeholder<2>, unsigned int)> > >(boost::asio::detail::binder2<AllocHandler<std::_Bind<std::_Mem_fn<void (pulsar::ClientConnection::*)(const boost::system::error_code&, long unsigned int, unsigned int)>(std::shared_ptr<pulsar::ClientConnection>, std::_Placeholder<1>, std::_Placeholder<2>, unsigned int)> >, boost::system::error_code, long unsigned int> &, AllocHandler<std::_Bind<std::_Mem_fn<void (pulsar::ClientConnection::*)(const boost::system::error_code&, long unsigned int, unsigned int)>(std::shared_ptr<pulsar::ClientConnection>, std::_Placeholder<1>, std::_Placeholder<2>, unsigned int)> > &) (function=..., context=...) at /usr/local/include/boost/asio/detail/handler_invoke_helpers.hpp:37
#24 0x0000000000d4c6c8 in boost::asio::detail::reactive_socket_recv_op<boost::asio::mutable_buffers_1, AllocHandler<std::_Bind<std::_Mem_fn<void (pulsar::ClientConnection::*)(boost::system::error_code const&, unsigned long, unsigned int)> (std::shared_ptr<pulsar::ClientConnection>, std::_Placeholder<1>, std::_Placeholder<2>, unsigned int)> > >::do_complete(boost::asio::detail::task_io_service*, boost::asio::detail::task_io_service_operation*, boost::system::error_code const&, unsigned long) (owner=0xce020b0, base=<optimized out>) at /usr/local/include/boost/asio/detail/reactive_socket_recv_op.hpp:110
#25 0x0000000000c7bcdf in complete (bytes_transferred=<optimized out>, ec=..., owner=..., this=0xd0f50e0) at /usr/local/include/boost/asio/detail/task_io_service_operation.hpp:37
#26 do_run_one (ec=..., this_thread=..., lock=..., this=0xce020b0) at /usr/local/include/boost/asio/detail/impl/task_io_service.ipp:384
#27 boost::asio::detail::task_io_service::run (this=0xce020b0, ec=...) at /usr/local/include/boost/asio/detail/impl/task_io_service.ipp:153
#28 0x0000000000c77b2a in run (this=<optimized out>, ec=...) at /usr/local/include/boost/asio/impl/io_service.ipp:66
#29 pulsar::ExecutorService::__lambda0::operator() (__closure=0xd10efb0) at /data/workspace/third-party-lib/pulsar-2.10.1/pulsar-client-cpp/lib/ExecutorService.cc:43
#30 0x00007f454943f340 in ?? () from /lib64/libstdc++.so.6
#31 0x00007f4548f5fea5 in start_thread () from /lib64/libpthread.so.0
#32 0x00007f454857a9fd in clone () from /lib64/libc.so.6