activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From spamtrap <nospam.1.friedbad...@spamgourmet.com>
Subject Re: Program hangs if wrong broker port is used
Date Mon, 15 Aug 2016 13:53:40 GMT
On Mon, 15 Aug 2016 09:06:42 -0400, Timothy Bish
<tabish121@gmail.com> wrote:

Thanks for the reply.  However the broker string is configured by the
client so we cannot guarantee that it will be correct.

Our thoughts is to set startupMaxReconnectAttempts to >0.  Will this
stop it hanging?

>You are using failover so the client is attempting to reconnect, since 
>the port is wrong it never will obviously so giving it the correct port 
>is the way to go.
>
>On 08/15/2016 08:34 AM, spamtrap wrote:
>> If the wrong port is given when trying to connect to a broker then we
>> get a hanging problem.  The stack backtrace is:
>>
>> #0  0x00007f0ca3837a82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from
>> /usr/lib64/libpthread.so.0
>> (gdb) bt
>> #0  0x00007f0ca3837a82 in pthread_cond_timedwait@@GLIBC_2.3.2 () from
>> /usr/lib64/libpthread.so.0
>> #1  0x00007f0caa023db6 in
>> decaf::internal::util::concurrent::PlatformThread::interruptibleWaitOnCondition
>> (condition=0x1571040, mutex=0x1607090, mills=100, nanos=0,
>> complete=...)
>>      at decaf/internal/util/concurrent/unix/PlatformThread.cpp:239
>> #2  0x00007f0caa022220 in doWaitOnMonitor (nanos=0, mills=100,
>> thread=0x15711c0, monitor=0x7f0b94003570, interruptible=<optimized
>> out>) at decaf/internal/util/concurrent/Threading.cpp:750
>> #3  decaf::internal::util::concurrent::Threading::waitOnMonitor
>> (monitor=0x7f0b94003570, mills=100, nanos=0) at
>> decaf/internal/util/concurrent/Threading.cpp:1565
>> #4  0x00007f0ca9f0d282 in
>> activemq::transport::failover::FailoverTransport::oneway
>> (this=0x1603780, command=...) at
>> activemq/transport/failover/FailoverTransport.cpp:445
>> #5  0x00007f0ca9ed720f in
>> activemq::transport::correlator::ResponseCorrelator::request
>> (this=<optimized out>, command=...) at
>> activemq/transport/correlator/ResponseCorrelator.cpp:218
>> #6  0x00007f0ca9ce02ae in
>> activemq::core::ActiveMQConnection::syncRequest (this=<optimized out>,
>> command=..., timeout=<optimized out>) at
>> activemq/core/ActiveMQConnection.cpp:1276
>> #7  0x00007f0ca9ce2fa7 in
>> activemq::core::ActiveMQConnection::ensureConnectionInfoSent
>> (this=0x1606d40) at activemq/core/ActiveMQConnection.cpp:1357
>> #8  0x00007f0ca9ce614c in
>> activemq::core::ActiveMQConnection::setClientID (this=0x1606d40,
>> clientID=...) at activemq/core/ActiveMQConnection.cpp:669
>>
>> What's the best way to prevent it hanging in this situation?
>>
>> If a man stands in a forest and no woman is around to hear him, is he still wrong?
>>
>>



Mime
View raw message