Hi Tim and Oscar,
thanks for your attention,
So, in my case i got frozen in a commit attempt.
But really, testing without transaction and MessageListener i got
frozen in consumer destructor too.
Maybe it's the same reason for both cases. I tested with several
configurations to try avoid freezes for both cases.
I opened the AMQCPP-354 issue with 'unexpected exception' report, but
i think that these cases deserve more one (or two) new issues in Jira
for later investigation.
regards
Henrique
Following how to reproduce the cases:
MESSAGELISTENER WITH TRANSACTION, FREEZES IN COMMIT
MessageListener consumer destructor freezes in commit:
1- Start ActiveMQ
2- Start 'MessageListener' consumer './activemqTest -l -c1 -d10000'
3- Send one message './activemqTest -p1'
4- Wait consumer 'Starting delay'
5- Stop ActiveMQ
6- Consumer will try commit
8- Freezes (see below 'BACKTRACE 1')!!!
MESSAGELISTENER WITHOUT TRANSACTION, FREEZES IN DESTRUCTOR
MessageListener consumer destructor freezes (apply changes in test code):
1- Start ActiveMQ
2- Start 'MessageListener' consumer './activemqTest -l -c1 -d10000'
3- Send one message './activemqTest -p1'
4- Wait consumer 'Starting delay'
5- Stop ActiveMQ
6- Wait consumer delay finishes 'Delay finish'
7- Try kill consumer ( not kill -9 :-) )
8- Freezes (see below 'BACKTRACE 2')!!!
Changes in test:
@@ -440,6 +440,7 @@
if(_delay) {
std::cout<<"Starting delay..."<<std::endl;
stopCheck(_delay);
+ std::cout<<"Delay finish..."<<std::endl;
}
} catch (CMSException& e) {
@@ -561,7 +562,7 @@
void loadEndPoins() {
for(int i=0; i<_consumer;i++) {
- _endPointList.push_back( new
Consumer(&_poolManager,"TEST.FOO",_delay,_useListener) );
+ _endPointList.push_back( new
Consumer(&_poolManager,"TEST.FOO",_delay,_useListener,false) );
}
for(int i=0; i<_producer;i++) {
_endPointList.push_back( new
Producer(&_poolManager,"TEST.FOO",_delay,_numMessages) );
BACKTRACE 1:
Thread 1:
#0 0x00eed422 in __kernel_vsyscall ()
#1 0x00468b5d in pthread_join (threadid=3061414768,
thread_return=0xbf951e8c) at pthread_join.c:89
#2 0x00be23c0 in decaf::lang::Thread::join (this=0x9551574) at
decaf/lang/Thread.cpp:421
#3 0x0804c9f1 in AppTest::joinEndPoins (this=0xbf951f14) at main.cpp:586
#4 0x0804c678 in AppTest::run (this=0xbf951f14) at main.cpp:555
#5 0x0804a33c in main (argc=4, argv=0xbf952034) at main.cpp:633
Thread 2:
#0 0x00eed422 in __kernel_vsyscall ()
#1 0x0046c015 in pthread_cond_wait@@GLIBC_2.3.2 () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/pthread_cond_wait.S:122
#2 0x003259dd in __pthread_cond_wait (cond=0x9547e38,
mutex=0x9547e08) at forward.c:139
#3 0x00bb06a9 in
decaf::internal::util::concurrent::ConditionImpl::wait
(condition=0x9547e38) at
decaf/internal/util/concurrent/unix/ConditionImpl.cpp:94
#4 0x00c21353 in decaf::util::concurrent::Mutex::wait
(this=0x9547d6c) at decaf/util/concurrent/Mutex.cpp:95
#5 0x0094c9c5 in activemq::threads::CompositeTaskRunner::run
(this=0x9547d48) at activemq/threads/CompositeTaskRunner.cpp:118
#6 0x00be3cf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x9547e90) at decaf/lang/Thread.cpp:135
#7 0x00be2847 in threadWorker (arg=0x9547e90) at decaf/lang/Thread.cpp:188
#8 0x0046796e in start_thread (arg=0xb7799b70) at pthread_create.c:300
#9 0x00318a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
Thread 3:
#0 0x00eed422 in __kernel_vsyscall ()
#1 0x0046eaf9 in __lll_lock_wait () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142
#2 0x0046a13b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so.0
#3 0x00469f61 in __pthread_mutex_lock (mutex=0x95523a8) at
pthread_mutex_lock.c:61
#4 0x00325ba6 in pthread_mutex_lock (mutex=0x95523a8) at forward.c:182
#5 0x00bb0aa1 in decaf::internal::util::concurrent::MutexImpl::lock
(handle=0x95523a8) at
decaf/internal/util/concurrent/unix/MutexImpl.cpp:71
#6 0x00c21412 in decaf::util::concurrent::Mutex::lock
(this=0x95522bc) at decaf/util/concurrent/Mutex.cpp:75
#7 0x00915770 in
decaf::util::StlQueue<decaf::lang::Pointer<activemq::commands::MessageDispatch,
decaf::util::concurrent::atomic::AtomicRefCounter> >::lock
(this=0x95522a8)
at ./decaf/util/StlQueue.h:253
#8 activemq::core::MessageDispatchChannel::lock (this=0x95522a8) at
activemq/core/MessageDispatchChannel.h:153
#9 0x00c20ab5 in decaf::util::concurrent::Lock::lock
(this=0xb6f97fe4) at decaf/util/concurrent/Lock.cpp:54
#10 0x00c20c08 in Lock (this=0xfffffe00, object=0x95523a8,
intiallyLocked=true) at decaf/util/concurrent/Lock.cpp:32
#11 0x008de102 in
activemq::core::ActiveMQConsumer::clearMessagesInProgress
(this=0x9552270) at activemq/core/ActiveMQConsumer.cpp:1112
#12 0x008ff15c in
activemq::core::ActiveMQSession::clearMessagesInProgress
(this=0x9551b90) at activemq/core/ActiveMQSession.cpp:239
#13 0x008c8543 in
activemq::core::ActiveMQConnection::transportInterrupted
(this=0x9548210) at activemq/core/ActiveMQConnection.cpp:704
#14 0x00953b34 in
activemq::transport::TransportFilter::transportInterrupted
(this=0x95481c0) at activemq/transport/TransportFilter.cpp:67
#15 0x009687ae in
activemq::transport::failover::FailoverTransport::handleTransportFailure
(this=0x9547a38, error=...) at
activemq/transport/failover/FailoverTransport.cpp:476
#16 0x0097406c in
activemq::transport::failover::FailoverTransportListener::onException
(this=0x9547878, ex=...) at
activemq/transport/failover/FailoverTransportListener.cpp:97
#17 0x00953c0b in activemq::transport::TransportFilter::fire
(this=0x9549d80, ex=...) at activemq/transport/TransportFilter.cpp:49
#18 0x00953c64 in activemq::transport::TransportFilter::onException
(this=0x9549d80, ex=...) at activemq/transport/TransportFilter.cpp:41
#19 0x00953c0b in activemq::transport::TransportFilter::fire
(this=0x95497f0, ex=...) at activemq/transport/TransportFilter.cpp:49
#20 0x00953c64 in activemq::transport::TransportFilter::onException
(this=0x95497f0, ex=...) at activemq/transport/TransportFilter.cpp:41
#21 0x00951b13 in activemq::transport::IOTransport::fire
(this=0x95497a0, ex=...) at activemq/transport/IOTransport.cpp:73
#22 0x009523bf in activemq::transport::IOTransport::run
(this=0x95497a0) at activemq/transport/IOTransport.cpp:246
#23 0x00be3cf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x9549ea0) at decaf/lang/Thread.cpp:135
#24 0x00be2847 in threadWorker (arg=0x9549ea0) at decaf/lang/Thread.cpp:188
#25 0x0046796e in start_thread (arg=0xb6f98b70) at pthread_create.c:300
#26 0x00318a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
Thread 4:
#0 0x00eed422 in __kernel_vsyscall ()
#1 0x0046c015 in pthread_cond_wait@@GLIBC_2.3.2 () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/pthread_cond_wait.S:122
#2 0x003259dd in __pthread_cond_wait (cond=0x95516c8,
mutex=0x9551698) at forward.c:139
#3 0x00bb06a9 in
decaf::internal::util::concurrent::ConditionImpl::wait
(condition=0x95516c8) at
decaf/internal/util/concurrent/unix/ConditionImpl.cpp:94
#4 0x00c21353 in decaf::util::concurrent::Mutex::wait
(this=0x9551584) at decaf/util/concurrent/Mutex.cpp:95
#5 0x00c2029a in decaf::util::concurrent::CountDownLatch::await
(this=0x955157c) at decaf/util/concurrent/CountDownLatch.cpp:56
#6 0x0804af84 in JMSEndPointThread::stopCheck (this=0x9551574,
timeOut=-1) at main.cpp:226
#7 0x0804bb46 in Consumer::run (this=0x9551570) at main.cpp:379
#8 0x00be3cf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x95515b0) at decaf/lang/Thread.cpp:135
#9 0x00be2847 in threadWorker (arg=0x95515b0) at decaf/lang/Thread.cpp:188
#10 0x0046796e in start_thread (arg=0xb6797b70) at pthread_create.c:300
#11 0x00318a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
Thread 5:
#0 0x00eed422 in __kernel_vsyscall ()
#1 0x0046eaf9 in __lll_lock_wait () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142
#2 0x0046a13b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so.0
#3 0x00469f61 in __pthread_mutex_lock (mutex=0x95475e0) at
pthread_mutex_lock.c:61
#4 0x00325ba6 in pthread_mutex_lock (mutex=0x95475e0) at forward.c:182
#5 0x00bb0aa1 in decaf::internal::util::concurrent::MutexImpl::lock
(handle=0x95475e0) at
decaf/internal/util/concurrent/unix/MutexImpl.cpp:71
#6 0x00c21412 in decaf::util::concurrent::Mutex::lock
(this=0x9547a88) at decaf/util/concurrent/Mutex.cpp:75
#7 0x00c20ab5 in decaf::util::concurrent::Lock::lock
(this=0xb5f95ce0) at decaf/util/concurrent/Lock.cpp:54
#8 0x00c20c08 in Lock (this=0xfffffe00, object=0x95475e0,
intiallyLocked=true) at decaf/util/concurrent/Lock.cpp:32
#9 0x0096b8fd in
activemq::transport::failover::FailoverTransport::oneway
(this=0x9547a38, command=...) at
activemq/transport/failover/FailoverTransport.cpp:186
#10 0x00957f9f in
activemq::transport::correlator::ResponseCorrelator::oneway
(this=0x95481c0, command=...) at
activemq/transport/correlator/ResponseCorrelator.cpp:82
#11 0x008c13be in activemq::core::ActiveMQConnection::oneway
(this=0x9548210, command=...) at
activemq/core/ActiveMQConnection.cpp:741
#12 0x00900a4f in activemq::core::ActiveMQSession::oneway
(this=0x9551b90, command=...) at activemq/core/ActiveMQSession.cpp:903
#13 0x008e5a1c in activemq::core::ActiveMQConsumer::acknowledge
(this=0x9552270) at activemq/core/ActiveMQConsumer.cpp:860
#14 0x008ef885 in
activemq::core::TransactionSynhcronization::beforeEnd (this=0x95529e8)
at activemq/core/ActiveMQConsumer.cpp:85
#15 0x00910588 in
activemq::core::ActiveMQTransactionContext::beforeEnd (this=0x9551dc8)
at activemq/core/ActiveMQTransactionContext.cpp:192
#16 0x00910d63 in activemq::core::ActiveMQTransactionContext::commit
(this=0x9551dc8) at activemq/core/ActiveMQTransactionContext.cpp:127
#17 0x008fe460 in activemq::core::ActiveMQSession::commit
(this=0x9551b90) at activemq/core/ActiveMQSession.cpp:189
#18 0x007ec1a0 in activemq::cmsutil::PooledSession::commit
(this=0x9551f38) at activemq/cmsutil/PooledSession.h:87
#19 0x0804c0fb in Consumer::onMessage (this=0x9551570,
message=0x9552ec0) at main.cpp:455
#20 0x008e972f in activemq::core::ActiveMQConsumer::dispatch
(this=0x9552270, dispatch=...) at
activemq/core/ActiveMQConsumer.cpp:1018
#21 0x0090d5c3 in activemq::core::ActiveMQSessionExecutor::dispatch
(this=0x9551e78, dispatch=...) at
activemq/core/ActiveMQSessionExecutor.cpp:129
#22 0x0090d993 in activemq::core::ActiveMQSessionExecutor::iterate
(this=0x9551e78) at activemq/core/ActiveMQSessionExecutor.cpp:166
#23 0x009507f3 in activemq::threads::DedicatedTaskRunner::run
(this=0x9552550) at activemq/threads/DedicatedTaskRunner.cpp:111
#24 0x00be3cf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x9551ad8) at decaf/lang/Thread.cpp:135
#25 0x00be2847 in threadWorker (arg=0x9551ad8) at decaf/lang/Thread.cpp:188
#26 0x0046796e in start_thread (arg=0xb5f96b70) at pthread_create.c:300
#27 0x00318a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
BACKTRACE 2:
Thread 1:
#0 0x0079b422 in __kernel_vsyscall ()
#1 0x008bfb5d in pthread_join (threadid=3061021552,
thread_return=0xbfbff07c) at pthread_join.c:89
#2 0x0132a3c0 in decaf::lang::Thread::join (this=0x9be0574) at
decaf/lang/Thread.cpp:421
#3 0x0804ca15 in AppTest::joinEndPoins (this=0xbfbff104) at main.cpp:587
#4 0x0804c69c in AppTest::run (this=0xbfbff104) at main.cpp:556
#5 0x0804a33c in main (argc=4, argv=0xbfbff224) at main.cpp:634
Thread 2:
#0 0x0079b422 in __kernel_vsyscall ()
#1 0x008c3015 in pthread_cond_wait@@GLIBC_2.3.2 () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/pthread_cond_wait.S:122
#2 0x004ed9dd in __pthread_cond_wait (cond=0x9bd6e38,
mutex=0x9bd6e08) at forward.c:139
#3 0x012f86a9 in
decaf::internal::util::concurrent::ConditionImpl::wait
(condition=0x9bd6e38) at
decaf/internal/util/concurrent/unix/ConditionImpl.cpp:94
#4 0x01369353 in decaf::util::concurrent::Mutex::wait
(this=0x9bd6d6c) at decaf/util/concurrent/Mutex.cpp:95
#5 0x010949c5 in activemq::threads::CompositeTaskRunner::run
(this=0x9bd6d48) at activemq/threads/CompositeTaskRunner.cpp:118
#6 0x0132bcf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x9bd6e90) at decaf/lang/Thread.cpp:135
#7 0x0132a847 in threadWorker (arg=0x9bd6e90) at decaf/lang/Thread.cpp:188
#8 0x008be96e in start_thread (arg=0xb7739b70) at pthread_create.c:300
#9 0x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
Thread 3:
#0 0x0079b422 in __kernel_vsyscall ()
#1 0x008c5af9 in __lll_lock_wait () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142
#2 0x008c113b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so.0
#3 0x008c0f61 in __pthread_mutex_lock (mutex=0x9be12d8) at
pthread_mutex_lock.c:61
#4 0x004edba6 in pthread_mutex_lock (mutex=0x9be12d8) at forward.c:182
#5 0x012f8aa1 in decaf::internal::util::concurrent::MutexImpl::lock
(handle=0x9be12d8) at
decaf/internal/util/concurrent/unix/MutexImpl.cpp:71
#6 0x01369412 in decaf::util::concurrent::Mutex::lock
(this=0x9be11ec) at decaf/util/concurrent/Mutex.cpp:75
#7 0x0105d770 in
decaf::util::StlQueue<decaf::lang::Pointer<activemq::commands::MessageDispatch,
decaf::util::concurrent::atomic::AtomicRefCounter> >::lock
(this=0x9be11d8)
at ./decaf/util/StlQueue.h:253
#8 activemq::core::MessageDispatchChannel::lock (this=0x9be11d8) at
activemq/core/MessageDispatchChannel.h:153
#9 0x01368ab5 in decaf::util::concurrent::Lock::lock
(this=0xb6f37fe4) at decaf/util/concurrent/Lock.cpp:54
#10 0x01368c08 in Lock (this=0xfffffe00, object=0x9be12d8,
intiallyLocked=true) at decaf/util/concurrent/Lock.cpp:32
#11 0x01026102 in
activemq::core::ActiveMQConsumer::clearMessagesInProgress
(this=0x9be11a0) at activemq/core/ActiveMQConsumer.cpp:1112
#12 0x0104715c in
activemq::core::ActiveMQSession::clearMessagesInProgress
(this=0x9be0b90) at activemq/core/ActiveMQSession.cpp:239
#13 0x01010543 in
activemq::core::ActiveMQConnection::transportInterrupted
(this=0x9bd7210) at activemq/core/ActiveMQConnection.cpp:704
#14 0x0109bb34 in
activemq::transport::TransportFilter::transportInterrupted
(this=0x9bd71c0) at activemq/transport/TransportFilter.cpp:67
#15 0x010b07ae in
activemq::transport::failover::FailoverTransport::handleTransportFailure
(this=0x9bd6a38, error=...) at
activemq/transport/failover/FailoverTransport.cpp:476
#16 0x010bc06c in
activemq::transport::failover::FailoverTransportListener::onException
(this=0x9bd6878, ex=...) at
activemq/transport/failover/FailoverTransportListener.cpp:97
#17 0x0109bc0b in activemq::transport::TransportFilter::fire
(this=0x9bd8ec8, ex=...) at activemq/transport/TransportFilter.cpp:49
#18 0x0109bc64 in activemq::transport::TransportFilter::onException
(this=0x9bd8ec8, ex=...) at activemq/transport/TransportFilter.cpp:41
#19 0x0109bc0b in activemq::transport::TransportFilter::fire
(this=0x9bd8938, ex=...) at activemq/transport/TransportFilter.cpp:49
#20 0x0109bc64 in activemq::transport::TransportFilter::onException
(this=0x9bd8938, ex=...) at activemq/transport/TransportFilter.cpp:41
#21 0x01099b13 in activemq::transport::IOTransport::fire
(this=0x9bd88e8, ex=...) at activemq/transport/IOTransport.cpp:73
#22 0x0109a3bf in activemq::transport::IOTransport::run
(this=0x9bd88e8) at activemq/transport/IOTransport.cpp:246
#23 0x0132bcf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x9bd8fe8) at decaf/lang/Thread.cpp:135
#24 0x0132a847 in threadWorker (arg=0x9bd8fe8) at decaf/lang/Thread.cpp:188
#25 0x008be96e in start_thread (arg=0xb6f38b70) at pthread_create.c:300
#26 0x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
Thread 4:
#0 0x0079b422 in __kernel_vsyscall ()
#1 0x008c5af9 in __lll_lock_wait () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142
#2 0x008c113b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so.0
#3 0x008c0f61 in __pthread_mutex_lock (mutex=0x9be12d8) at
pthread_mutex_lock.c:61
#4 0x004edba6 in pthread_mutex_lock (mutex=0x9be12d8) at forward.c:182
#5 0x012f8aa1 in decaf::internal::util::concurrent::MutexImpl::lock
(handle=0x9be12d8) at
decaf/internal/util/concurrent/unix/MutexImpl.cpp:71
#6 0x01369412 in decaf::util::concurrent::Mutex::lock
(this=0x9be11ec) at decaf/util/concurrent/Mutex.cpp:75
#7 0x01036830 in
decaf::util::StlQueue<decaf::lang::Pointer<activemq::commands::MessageDispatch,
decaf::util::concurrent::atomic::AtomicRefCounter> >::lock
(this=0x9be11e0)
at ./decaf/util/StlQueue.h:253
#8 0x01368ab5 in decaf::util::concurrent::Lock::lock
(this=0xb6737064) at decaf/util/concurrent/Lock.cpp:54
#9 0x01368c08 in Lock (this=0xfffffe00, object=0x9be12d8,
intiallyLocked=true) at decaf/util/concurrent/Lock.cpp:32
#10 0x0105c507 in activemq::core::MessageDispatchChannel::clear
(this=0x9be11d8) at activemq/core/MessageDispatchChannel.cpp:143
#11 0x0102ec37 in activemq::core::ActiveMQConsumer::doClose
(this=0x9be11a0) at activemq/core/ActiveMQConsumer.cpp:335
#12 0x0102fb00 in activemq::core::ActiveMQConsumer::close
(this=0x9be11a0) at activemq/core/ActiveMQConsumer.cpp:309
#13 0x01030390 in ~ActiveMQConsumer (this=0x9be11a0, __in_chrg=<value
optimized out>) at activemq/core/ActiveMQConsumer.cpp:261
#14 0x0804c276 in Consumer::cleanup (this=0x9be0570) at main.cpp:469
#15 0x0804bcdd in Consumer::run (this=0x9be0570) at main.cpp:394
#16 0x0132bcf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x9be05b0) at decaf/lang/Thread.cpp:135
#17 0x0132a847 in threadWorker (arg=0x9be05b0) at decaf/lang/Thread.cpp:188
#18 0x008be96e in start_thread (arg=0xb6737b70) at pthread_create.c:300
#19 0x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
Thread 5:
#0 0x0079b422 in __kernel_vsyscall ()
#1 0x008c5af9 in __lll_lock_wait () at
../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142
#2 0x008c113b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so.0
#3 0x008c0f61 in __pthread_mutex_lock (mutex=0x9bd65e0) at
pthread_mutex_lock.c:61
#4 0x004edba6 in pthread_mutex_lock (mutex=0x9bd65e0) at forward.c:182
#5 0x012f8aa1 in decaf::internal::util::concurrent::MutexImpl::lock
(handle=0x9bd65e0) at
decaf/internal/util/concurrent/unix/MutexImpl.cpp:71
#6 0x01369412 in decaf::util::concurrent::Mutex::lock
(this=0x9bd6a88) at decaf/util/concurrent/Mutex.cpp:75
#7 0x01368ab5 in decaf::util::concurrent::Lock::lock
(this=0xb5f35ea0) at decaf/util/concurrent/Lock.cpp:54
#8 0x01368c08 in Lock (this=0xfffffe00, object=0x9bd65e0,
intiallyLocked=true) at decaf/util/concurrent/Lock.cpp:32
#9 0x010b38fd in
activemq::transport::failover::FailoverTransport::oneway
(this=0x9bd6a38, command=...) at
activemq/transport/failover/FailoverTransport.cpp:186
#10 0x0109ff9f in
activemq::transport::correlator::ResponseCorrelator::oneway
(this=0x9bd71c0, command=...) at
activemq/transport/correlator/ResponseCorrelator.cpp:82
#11 0x010093be in activemq::core::ActiveMQConnection::oneway
(this=0x9bd7210, command=...) at
activemq/core/ActiveMQConnection.cpp:741
#12 0x01048a4f in activemq::core::ActiveMQSession::oneway
(this=0x9be0b90, command=...) at activemq/core/ActiveMQSession.cpp:903
#13 0x01030df4 in
activemq::core::ActiveMQConsumer::afterMessageIsConsumed
(this=0x9be11a0, message=..., messageExpired=false) at
activemq/core/ActiveMQConsumer.cpp:642
#14 0x01031743 in activemq::core::ActiveMQConsumer::dispatch
(this=0x9be11a0, dispatch=...) at
activemq/core/ActiveMQConsumer.cpp:1021
#15 0x010555c3 in activemq::core::ActiveMQSessionExecutor::dispatch
(this=0x9be0dc8, dispatch=...) at
activemq/core/ActiveMQSessionExecutor.cpp:129
#16 0x01055993 in activemq::core::ActiveMQSessionExecutor::iterate
(this=0x9be0dc8) at activemq/core/ActiveMQSessionExecutor.cpp:166
#17 0x010987f3 in activemq::threads::DedicatedTaskRunner::run
(this=0x9be1480) at activemq/threads/DedicatedTaskRunner.cpp:111
#18 0x0132bcf1 in decaf::lang::ThreadProperties::runCallback
(properties=0x9be0ad8) at decaf/lang/Thread.cpp:135
#19 0x0132a847 in threadWorker (arg=0x9be0ad8) at decaf/lang/Thread.cpp:188
#20 0x008be96e in start_thread (arg=0xb5f36b70) at pthread_create.c:300
#21 0x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130
2011/3/1 Oscar Pernas <os...@pernas.es>
>
> Hi,
>
> I ran into this bug before. If I am shutting down and starting the broker so
> many times, connection are not reestablished and the consumer gets frozen.
> If you try to close the consumer that is frozen, the closing stucks your
> thread too? In my case, this problem only happens when I'm debugging the
> application (without breaks but with visual studio debug).
> I've partially resolved it manually, if I dont received anything over a
> topic in a time, I try to close the consumer and reconnect it again.
>
> regards
>
> --
> Óscar Pernas Plaza.
