Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 80981 invoked from network); 4 Mar 2011 18:52:16 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 4 Mar 2011 18:52:16 -0000 Received: (qmail 55130 invoked by uid 500); 4 Mar 2011 18:52:16 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 55101 invoked by uid 500); 4 Mar 2011 18:52:16 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 55093 invoked by uid 99); 4 Mar 2011 18:52:16 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 04 Mar 2011 18:52:16 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=FREEMAIL_FROM,RCVD_IN_DNSWL_LOW,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of magarotto@gmail.com designates 209.85.216.43 as permitted sender) Received: from [209.85.216.43] (HELO mail-qw0-f43.google.com) (209.85.216.43) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 04 Mar 2011 18:52:10 +0000 Received: by qwb7 with SMTP id 7so2218587qwb.2 for ; Fri, 04 Mar 2011 10:51:49 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:in-reply-to:references:date :message-id:subject:from:to:cc:content-type :content-transfer-encoding; bh=rjsWOVjj9yOa23b4O0hHL1Nt9i51NprqK51Y48LiuXM=; b=PMaa+lOnzebnWV+JdQKPCXZkHFOuv0Imh0tvSP0H3s/oNtiu6Pu3RcMnOCeA9kQ5tO 4ZTqhyz1ql1jIC7P/Yz1FohsBF/el53RoyQqJDEOpeSwRgh1mzT0O2jpLZ5VQ6LH71n6 epXNOxvOez5cGnPMMWXd/V8mHpqQ9vDtBcgNU= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :cc:content-type:content-transfer-encoding; b=mQnNp6a/yLyJp2HEGiFeKnLUlMHm5e4JOakmhRc4AF/b4D9Tvr5/0yvhLN9f9eTvaE tJxEunu1Eziek0bNcow9BlJ22drS8/lHh+5JLcZE0k7CB4mJMi4d7u48+mridkDXrH7A mugVXNgWv9eL5/4i/DLCpgqgth3umGKj99s3A= MIME-Version: 1.0 Received: by 10.229.101.79 with SMTP id b15mr864963qco.119.1299264709674; Fri, 04 Mar 2011 10:51:49 -0800 (PST) Received: by 10.229.228.137 with HTTP; Fri, 4 Mar 2011 10:51:49 -0800 (PST) In-Reply-To: References: <1299022276.2788.3.camel@office> Date: Fri, 4 Mar 2011 15:51:49 -0300 Message-ID: Subject: Re: AMQCPP: unexpected exception From: Henrique Magarotto To: users@activemq.apache.org Cc: Oscar Pernas , Timothy Bish Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable 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 =C2=A0cases. 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 @@ =C2=A0=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 if(_delay) { =C2=A0=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 std::cout<<"S= tarting delay..."< >::lock (this=3D0x95522a8) =C2=A0=C2=A0 =C2=A0at ./decaf/util/StlQueue.h:253 #8 =C2=A0activemq::core::MessageDispatchChannel::lock (this=3D0x95522a8) at activemq/core/MessageDispatchChannel.h:153 #9 =C2=A00x00c20ab5 in decaf::util::concurrent::Lock::lock (this=3D0xb6f97fe4) at decaf/util/concurrent/Lock.cpp:54 #10 0x00c20c08 in Lock (this=3D0xfffffe00, object=3D0x95523a8, intiallyLocked=3Dtrue) at decaf/util/concurrent/Lock.cpp:32 #11 0x008de102 in activemq::core::ActiveMQConsumer::clearMessagesInProgress (this=3D0x9552270) at activemq/core/ActiveMQConsumer.cpp:1112 #12 0x008ff15c in activemq::core::ActiveMQSession::clearMessagesInProgress (this=3D0x9551b90) at activemq/core/ActiveMQSession.cpp:239 #13 0x008c8543 in activemq::core::ActiveMQConnection::transportInterrupted (this=3D0x9548210) at activemq/core/ActiveMQConnection.cpp:704 #14 0x00953b34 in activemq::transport::TransportFilter::transportInterrupted (this=3D0x95481c0) at activemq/transport/TransportFilter.cpp:67 #15 0x009687ae in activemq::transport::failover::FailoverTransport::handleTransportFailure (this=3D0x9547a38, error=3D...) at activemq/transport/failover/FailoverTransport.cpp:476 #16 0x0097406c in activemq::transport::failover::FailoverTransportListener::onException (this=3D0x9547878, ex=3D...) at activemq/transport/failover/FailoverTransportListener.cpp:97 #17 0x00953c0b in activemq::transport::TransportFilter::fire (this=3D0x9549d80, ex=3D...) at activemq/transport/TransportFilter.cpp:49 #18 0x00953c64 in activemq::transport::TransportFilter::onException (this=3D0x9549d80, ex=3D...) at activemq/transport/TransportFilter.cpp:41 #19 0x00953c0b in activemq::transport::TransportFilter::fire (this=3D0x95497f0, ex=3D...) at activemq/transport/TransportFilter.cpp:49 #20 0x00953c64 in activemq::transport::TransportFilter::onException (this=3D0x95497f0, ex=3D...) at activemq/transport/TransportFilter.cpp:41 #21 0x00951b13 in activemq::transport::IOTransport::fire (this=3D0x95497a0, ex=3D...) at activemq/transport/IOTransport.cpp:73 #22 0x009523bf in activemq::transport::IOTransport::run (this=3D0x95497a0) at activemq/transport/IOTransport.cpp:246 #23 0x00be3cf1 in decaf::lang::ThreadProperties::runCallback (properties=3D0x9549ea0) at decaf/lang/Thread.cpp:135 #24 0x00be2847 in threadWorker (arg=3D0x9549ea0) at decaf/lang/Thread.cpp:1= 88 #25 0x0046796e in start_thread (arg=3D0xb6f98b70) at pthread_create.c:300 #26 0x00318a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130 Thread 4: #0 =C2=A00x00eed422 in __kernel_vsyscall () #1 =C2=A00x0046c015 in pthread_cond_wait@@GLIBC_2.3.2 () at ../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/pthread_cond_wait.S:122 #2 =C2=A00x003259dd in __pthread_cond_wait (cond=3D0x95516c8, mutex=3D0x9551698) at forward.c:139 #3 =C2=A00x00bb06a9 in decaf::internal::util::concurrent::ConditionImpl::wait (condition=3D0x95516c8) at decaf/internal/util/concurrent/unix/ConditionImpl.cpp:94 #4 =C2=A00x00c21353 in decaf::util::concurrent::Mutex::wait (this=3D0x9551584) at decaf/util/concurrent/Mutex.cpp:95 #5 =C2=A00x00c2029a in decaf::util::concurrent::CountDownLatch::await (this=3D0x955157c) at decaf/util/concurrent/CountDownLatch.cpp:56 #6 =C2=A00x0804af84 in JMSEndPointThread::stopCheck (this=3D0x9551574, timeOut=3D-1) at main.cpp:226 #7 =C2=A00x0804bb46 in Consumer::run (this=3D0x9551570) at main.cpp:379 #8 =C2=A00x00be3cf1 in decaf::lang::ThreadProperties::runCallback (properties=3D0x95515b0) at decaf/lang/Thread.cpp:135 #9 =C2=A00x00be2847 in threadWorker (arg=3D0x95515b0) at decaf/lang/Thread.= cpp:188 #10 0x0046796e in start_thread (arg=3D0xb6797b70) at pthread_create.c:300 #11 0x00318a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130 Thread 5: #0 =C2=A00x00eed422 in __kernel_vsyscall () #1 =C2=A00x0046eaf9 in __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142 #2 =C2=A00x0046a13b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so= .0 #3 =C2=A00x00469f61 in __pthread_mutex_lock (mutex=3D0x95475e0) at pthread_mutex_lock.c:61 #4 =C2=A00x00325ba6 in pthread_mutex_lock (mutex=3D0x95475e0) at forward.c:= 182 #5 =C2=A00x00bb0aa1 in decaf::internal::util::concurrent::MutexImpl::lock (handle=3D0x95475e0) at decaf/internal/util/concurrent/unix/MutexImpl.cpp:71 #6 =C2=A00x00c21412 in decaf::util::concurrent::Mutex::lock (this=3D0x9547a88) at decaf/util/concurrent/Mutex.cpp:75 #7 =C2=A00x00c20ab5 in decaf::util::concurrent::Lock::lock (this=3D0xb5f95ce0) at decaf/util/concurrent/Lock.cpp:54 #8 =C2=A00x00c20c08 in Lock (this=3D0xfffffe00, object=3D0x95475e0, intiallyLocked=3Dtrue) at decaf/util/concurrent/Lock.cpp:32 #9 =C2=A00x0096b8fd in activemq::transport::failover::FailoverTransport::oneway (this=3D0x9547a38, command=3D...) at activemq/transport/failover/FailoverTransport.cpp:186 #10 0x00957f9f in activemq::transport::correlator::ResponseCorrelator::oneway (this=3D0x95481c0, command=3D...) at activemq/transport/correlator/ResponseCorrelator.cpp:82 #11 0x008c13be in activemq::core::ActiveMQConnection::oneway (this=3D0x9548210, command=3D...) at activemq/core/ActiveMQConnection.cpp:741 #12 0x00900a4f in activemq::core::ActiveMQSession::oneway (this=3D0x9551b90, command=3D...) at activemq/core/ActiveMQSession.cpp:903 #13 0x008e5a1c in activemq::core::ActiveMQConsumer::acknowledge (this=3D0x9552270) at activemq/core/ActiveMQConsumer.cpp:860 #14 0x008ef885 in activemq::core::TransactionSynhcronization::beforeEnd (this=3D0x95529e8) at activemq/core/ActiveMQConsumer.cpp:85 #15 0x00910588 in activemq::core::ActiveMQTransactionContext::beforeEnd (this=3D0x9551dc8) at activemq/core/ActiveMQTransactionContext.cpp:192 #16 0x00910d63 in activemq::core::ActiveMQTransactionContext::commit (this=3D0x9551dc8) at activemq/core/ActiveMQTransactionContext.cpp:127 #17 0x008fe460 in activemq::core::ActiveMQSession::commit (this=3D0x9551b90) at activemq/core/ActiveMQSession.cpp:189 #18 0x007ec1a0 in activemq::cmsutil::PooledSession::commit (this=3D0x9551f38) at activemq/cmsutil/PooledSession.h:87 #19 0x0804c0fb in Consumer::onMessage (this=3D0x9551570, message=3D0x9552ec0) at main.cpp:455 #20 0x008e972f in activemq::core::ActiveMQConsumer::dispatch (this=3D0x9552270, dispatch=3D...) at activemq/core/ActiveMQConsumer.cpp:1018 #21 0x0090d5c3 in activemq::core::ActiveMQSessionExecutor::dispatch (this=3D0x9551e78, dispatch=3D...) at activemq/core/ActiveMQSessionExecutor.cpp:129 #22 0x0090d993 in activemq::core::ActiveMQSessionExecutor::iterate (this=3D0x9551e78) at activemq/core/ActiveMQSessionExecutor.cpp:166 #23 0x009507f3 in activemq::threads::DedicatedTaskRunner::run (this=3D0x9552550) at activemq/threads/DedicatedTaskRunner.cpp:111 #24 0x00be3cf1 in decaf::lang::ThreadProperties::runCallback (properties=3D0x9551ad8) at decaf/lang/Thread.cpp:135 #25 0x00be2847 in threadWorker (arg=3D0x9551ad8) at decaf/lang/Thread.cpp:1= 88 #26 0x0046796e in start_thread (arg=3D0xb5f96b70) at pthread_create.c:300 #27 0x00318a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130 BACKTRACE 2: Thread 1: #0 =C2=A00x0079b422 in __kernel_vsyscall () #1 =C2=A00x008bfb5d in pthread_join (threadid=3D3061021552, thread_return=3D0xbfbff07c) at pthread_join.c:89 #2 =C2=A00x0132a3c0 in decaf::lang::Thread::join (this=3D0x9be0574) at decaf/lang/Thread.cpp:421 #3 =C2=A00x0804ca15 in AppTest::joinEndPoins (this=3D0xbfbff104) at main.cp= p:587 #4 =C2=A00x0804c69c in AppTest::run (this=3D0xbfbff104) at main.cpp:556 #5 =C2=A00x0804a33c in main (argc=3D4, argv=3D0xbfbff224) at main.cpp:634 Thread 2: #0 =C2=A00x0079b422 in __kernel_vsyscall () #1 =C2=A00x008c3015 in pthread_cond_wait@@GLIBC_2.3.2 () at ../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/pthread_cond_wait.S:122 #2 =C2=A00x004ed9dd in __pthread_cond_wait (cond=3D0x9bd6e38, mutex=3D0x9bd6e08) at forward.c:139 #3 =C2=A00x012f86a9 in decaf::internal::util::concurrent::ConditionImpl::wait (condition=3D0x9bd6e38) at decaf/internal/util/concurrent/unix/ConditionImpl.cpp:94 #4 =C2=A00x01369353 in decaf::util::concurrent::Mutex::wait (this=3D0x9bd6d6c) at decaf/util/concurrent/Mutex.cpp:95 #5 =C2=A00x010949c5 in activemq::threads::CompositeTaskRunner::run (this=3D0x9bd6d48) at activemq/threads/CompositeTaskRunner.cpp:118 #6 =C2=A00x0132bcf1 in decaf::lang::ThreadProperties::runCallback (properties=3D0x9bd6e90) at decaf/lang/Thread.cpp:135 #7 =C2=A00x0132a847 in threadWorker (arg=3D0x9bd6e90) at decaf/lang/Thread.= cpp:188 #8 =C2=A00x008be96e in start_thread (arg=3D0xb7739b70) at pthread_create.c:= 300 #9 =C2=A00x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:= 130 Thread 3: #0 =C2=A00x0079b422 in __kernel_vsyscall () #1 =C2=A00x008c5af9 in __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142 #2 =C2=A00x008c113b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so= .0 #3 =C2=A00x008c0f61 in __pthread_mutex_lock (mutex=3D0x9be12d8) at pthread_mutex_lock.c:61 #4 =C2=A00x004edba6 in pthread_mutex_lock (mutex=3D0x9be12d8) at forward.c:= 182 #5 =C2=A00x012f8aa1 in decaf::internal::util::concurrent::MutexImpl::lock (handle=3D0x9be12d8) at decaf/internal/util/concurrent/unix/MutexImpl.cpp:71 #6 =C2=A00x01369412 in decaf::util::concurrent::Mutex::lock (this=3D0x9be11ec) at decaf/util/concurrent/Mutex.cpp:75 #7 =C2=A00x0105d770 in decaf::util::StlQueue >::lock (this=3D0x9be11d8) =C2=A0=C2=A0 =C2=A0at ./decaf/util/StlQueue.h:253 #8 =C2=A0activemq::core::MessageDispatchChannel::lock (this=3D0x9be11d8) at activemq/core/MessageDispatchChannel.h:153 #9 =C2=A00x01368ab5 in decaf::util::concurrent::Lock::lock (this=3D0xb6f37fe4) at decaf/util/concurrent/Lock.cpp:54 #10 0x01368c08 in Lock (this=3D0xfffffe00, object=3D0x9be12d8, intiallyLocked=3Dtrue) at decaf/util/concurrent/Lock.cpp:32 #11 0x01026102 in activemq::core::ActiveMQConsumer::clearMessagesInProgress (this=3D0x9be11a0) at activemq/core/ActiveMQConsumer.cpp:1112 #12 0x0104715c in activemq::core::ActiveMQSession::clearMessagesInProgress (this=3D0x9be0b90) at activemq/core/ActiveMQSession.cpp:239 #13 0x01010543 in activemq::core::ActiveMQConnection::transportInterrupted (this=3D0x9bd7210) at activemq/core/ActiveMQConnection.cpp:704 #14 0x0109bb34 in activemq::transport::TransportFilter::transportInterrupted (this=3D0x9bd71c0) at activemq/transport/TransportFilter.cpp:67 #15 0x010b07ae in activemq::transport::failover::FailoverTransport::handleTransportFailure (this=3D0x9bd6a38, error=3D...) at activemq/transport/failover/FailoverTransport.cpp:476 #16 0x010bc06c in activemq::transport::failover::FailoverTransportListener::onException (this=3D0x9bd6878, ex=3D...) at activemq/transport/failover/FailoverTransportListener.cpp:97 #17 0x0109bc0b in activemq::transport::TransportFilter::fire (this=3D0x9bd8ec8, ex=3D...) at activemq/transport/TransportFilter.cpp:49 #18 0x0109bc64 in activemq::transport::TransportFilter::onException (this=3D0x9bd8ec8, ex=3D...) at activemq/transport/TransportFilter.cpp:41 #19 0x0109bc0b in activemq::transport::TransportFilter::fire (this=3D0x9bd8938, ex=3D...) at activemq/transport/TransportFilter.cpp:49 #20 0x0109bc64 in activemq::transport::TransportFilter::onException (this=3D0x9bd8938, ex=3D...) at activemq/transport/TransportFilter.cpp:41 #21 0x01099b13 in activemq::transport::IOTransport::fire (this=3D0x9bd88e8, ex=3D...) at activemq/transport/IOTransport.cpp:73 #22 0x0109a3bf in activemq::transport::IOTransport::run (this=3D0x9bd88e8) at activemq/transport/IOTransport.cpp:246 #23 0x0132bcf1 in decaf::lang::ThreadProperties::runCallback (properties=3D0x9bd8fe8) at decaf/lang/Thread.cpp:135 #24 0x0132a847 in threadWorker (arg=3D0x9bd8fe8) at decaf/lang/Thread.cpp:1= 88 #25 0x008be96e in start_thread (arg=3D0xb6f38b70) at pthread_create.c:300 #26 0x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130 Thread 4: #0 =C2=A00x0079b422 in __kernel_vsyscall () #1 =C2=A00x008c5af9 in __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142 #2 =C2=A00x008c113b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so= .0 #3 =C2=A00x008c0f61 in __pthread_mutex_lock (mutex=3D0x9be12d8) at pthread_mutex_lock.c:61 #4 =C2=A00x004edba6 in pthread_mutex_lock (mutex=3D0x9be12d8) at forward.c:= 182 #5 =C2=A00x012f8aa1 in decaf::internal::util::concurrent::MutexImpl::lock (handle=3D0x9be12d8) at decaf/internal/util/concurrent/unix/MutexImpl.cpp:71 #6 =C2=A00x01369412 in decaf::util::concurrent::Mutex::lock (this=3D0x9be11ec) at decaf/util/concurrent/Mutex.cpp:75 #7 =C2=A00x01036830 in decaf::util::StlQueue >::lock (this=3D0x9be11e0) =C2=A0=C2=A0 =C2=A0at ./decaf/util/StlQueue.h:253 #8 =C2=A00x01368ab5 in decaf::util::concurrent::Lock::lock (this=3D0xb6737064) at decaf/util/concurrent/Lock.cpp:54 #9 =C2=A00x01368c08 in Lock (this=3D0xfffffe00, object=3D0x9be12d8, intiallyLocked=3Dtrue) at decaf/util/concurrent/Lock.cpp:32 #10 0x0105c507 in activemq::core::MessageDispatchChannel::clear (this=3D0x9be11d8) at activemq/core/MessageDispatchChannel.cpp:143 #11 0x0102ec37 in activemq::core::ActiveMQConsumer::doClose (this=3D0x9be11a0) at activemq/core/ActiveMQConsumer.cpp:335 #12 0x0102fb00 in activemq::core::ActiveMQConsumer::close (this=3D0x9be11a0) at activemq/core/ActiveMQConsumer.cpp:309 #13 0x01030390 in ~ActiveMQConsumer (this=3D0x9be11a0, __in_chrg=3D) at activemq/core/ActiveMQConsumer.cpp:261 #14 0x0804c276 in Consumer::cleanup (this=3D0x9be0570) at main.cpp:469 #15 0x0804bcdd in Consumer::run (this=3D0x9be0570) at main.cpp:394 #16 0x0132bcf1 in decaf::lang::ThreadProperties::runCallback (properties=3D0x9be05b0) at decaf/lang/Thread.cpp:135 #17 0x0132a847 in threadWorker (arg=3D0x9be05b0) at decaf/lang/Thread.cpp:1= 88 #18 0x008be96e in start_thread (arg=3D0xb6737b70) at pthread_create.c:300 #19 0x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130 Thread 5: #0 =C2=A00x0079b422 in __kernel_vsyscall () #1 =C2=A00x008c5af9 in __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/i386/i686/../i486/lowlevellock.S:142 #2 =C2=A00x008c113b in _L_lock_748 () from /lib/tls/i686/cmov/libpthread.so= .0 #3 =C2=A00x008c0f61 in __pthread_mutex_lock (mutex=3D0x9bd65e0) at pthread_mutex_lock.c:61 #4 =C2=A00x004edba6 in pthread_mutex_lock (mutex=3D0x9bd65e0) at forward.c:= 182 #5 =C2=A00x012f8aa1 in decaf::internal::util::concurrent::MutexImpl::lock (handle=3D0x9bd65e0) at decaf/internal/util/concurrent/unix/MutexImpl.cpp:71 #6 =C2=A00x01369412 in decaf::util::concurrent::Mutex::lock (this=3D0x9bd6a88) at decaf/util/concurrent/Mutex.cpp:75 #7 =C2=A00x01368ab5 in decaf::util::concurrent::Lock::lock (this=3D0xb5f35ea0) at decaf/util/concurrent/Lock.cpp:54 #8 =C2=A00x01368c08 in Lock (this=3D0xfffffe00, object=3D0x9bd65e0, intiallyLocked=3Dtrue) at decaf/util/concurrent/Lock.cpp:32 #9 =C2=A00x010b38fd in activemq::transport::failover::FailoverTransport::oneway (this=3D0x9bd6a38, command=3D...) at activemq/transport/failover/FailoverTransport.cpp:186 #10 0x0109ff9f in activemq::transport::correlator::ResponseCorrelator::oneway (this=3D0x9bd71c0, command=3D...) at activemq/transport/correlator/ResponseCorrelator.cpp:82 #11 0x010093be in activemq::core::ActiveMQConnection::oneway (this=3D0x9bd7210, command=3D...) at activemq/core/ActiveMQConnection.cpp:741 #12 0x01048a4f in activemq::core::ActiveMQSession::oneway (this=3D0x9be0b90, command=3D...) at activemq/core/ActiveMQSession.cpp:903 #13 0x01030df4 in activemq::core::ActiveMQConsumer::afterMessageIsConsumed (this=3D0x9be11a0, message=3D..., messageExpired=3Dfalse) at activemq/core/ActiveMQConsumer.cpp:642 #14 0x01031743 in activemq::core::ActiveMQConsumer::dispatch (this=3D0x9be11a0, dispatch=3D...) at activemq/core/ActiveMQConsumer.cpp:1021 #15 0x010555c3 in activemq::core::ActiveMQSessionExecutor::dispatch (this=3D0x9be0dc8, dispatch=3D...) at activemq/core/ActiveMQSessionExecutor.cpp:129 #16 0x01055993 in activemq::core::ActiveMQSessionExecutor::iterate (this=3D0x9be0dc8) at activemq/core/ActiveMQSessionExecutor.cpp:166 #17 0x010987f3 in activemq::threads::DedicatedTaskRunner::run (this=3D0x9be1480) at activemq/threads/DedicatedTaskRunner.cpp:111 #18 0x0132bcf1 in decaf::lang::ThreadProperties::runCallback (properties=3D0x9be0ad8) at decaf/lang/Thread.cpp:135 #19 0x0132a847 in threadWorker (arg=3D0x9be0ad8) at decaf/lang/Thread.cpp:1= 88 #20 0x008be96e in start_thread (arg=3D0xb5f36b70) at pthread_create.c:300 #21 0x004e0a4e in clone () at ../sysdeps/unix/sysv/linux/i386/clone.S:130 2011/3/1 Oscar Pernas > > 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 > > -- > =C3=93scar Pernas Plaza.