[
https://issues.apache.org/jira/browse/AMQCPP-531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13880976#comment-13880976
]
Vincent Giacomini commented on AMQCPP-531:
------------------------------------------
below the stack trace giev by My IDE RDP (Rational developer for power)
_event_wait : libpthreads.a(shr_xpg5_64.o):.text
_cond_wait_local : libpthreads.a(shr_xpg5_64.o):.text
_cond_wait : libpthreads.a(shr_xpg5_64.o):.text
pthread_cond_wait : libpthreads.a(shr_xpg5_64.o):.text
interruptibleWaitOnCondition__Q5_5decaf8internal4util10concurrent14PlatformThreadFP14pthread_cond_tP15pthread_mutex_tRQ5_5decaf8internal4util10concurrent19CompletionCondition
: libactivemq-cpp.a(libactivemq-cpp.so.18):.text
park__Q5_5decaf8internal4util10concurrent9ThreadingFPQ3_5decaf4lang6ThreadLi :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
park__Q5_5decaf8internal4util10concurrent9ThreadingFPQ3_5decaf4lang6Thread :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
park__Q5_5decaf4util10concurrent5locks11LockSupportFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
parkAndCheckInterrupt__Q5_5decaf4util10concurrent5locks17SynchronizerStateCFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
acquireQueued__Q5_5decaf4util10concurrent5locks17SynchronizerStateFPQ2_32AbstractQueuedSynchronizer.cpp-04Nodei
: libactivemq-cpp.a(libactivemq-cpp.so.18):.text
acquire__Q5_5decaf4util10concurrent5locks26AbstractQueuedSynchronizerFi :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
lock__Q2_28ReentrantReadWriteLock.cpp-09WriteLockFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
removeConsumer__Q4_8activemq4core7kernels21ActiveMQSessionKernelFQ3_5decaf4lang7PointerXTQ4_8activemq4core7kernels22ActiveMQConsumerKernelTQ5_5decaf4util10concurrent6atomic16AtomicRefCounter_
: libactivemq-cpp.a(libactivemq-cpp.so.18):.text
dispose__Q4_8activemq4core7kernels22ActiveMQConsumerKernelFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
doClose__Q4_8activemq4core7kernels22ActiveMQConsumerKernelFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
close__Q4_8activemq4core7kernels22ActiveMQConsumerKernelFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
__dt__Q3_8activemq4core16ActiveMQConsumerFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
std::auto_ptr<cms::MessageConsumer>::~auto_ptr() : MsiScheduler.o
std::auto_ptr<cms::MessageConsumer>::__dftdt() : MsiScheduler.o
__Throw : libC.a(ansicore_64.o):.text
__DoThrowV6 : libC.a(ansicore_64.o):.text
receiveNoWait__Q3_8activemq4core16ActiveMQConsumerFv :
libactivemq-cpp.a(libactivemq-cpp.so.18):.text
msi::service::MsiScheduler::Run() : MsiScheduler.o
msi::service::MsiServer::start(int,char**,std::map<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,MsiService*,std::less<std::basic_string<char,std::char_traits<char>,std::allocator<char>
> >,std::allocator<std::pair<const
std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,MsiService*> > >&) : MsiServer.o
main : MsiServices.o
__start : crt0_64.o
Below the code doing the receiveNoWait:
// créer un consommateur général
std::auto_ptr<cms::MessageConsumer>
consumer(session->createConsumer(serviceQueue)) ;
std::stringstream ss ;
// crée un selecteur pour une message de vie pour ce processus
// exemple de selecteur ==> JMSType = 'aliveMsg' AND dest = '1'
ss << "JMSType = '" << msi::constant::process::alive_Rq_msgtype << "'
AND " << msi::constant::process::dest_alive_msgprop << " = '" << server.getId()
<< "'" ;
LOG4CXX_INFO(logger,"selecteur message de vie = " << ss.str()) ;
// créé un consommateur pour les messages de vie
std::auto_ptr<cms::MessageConsumer>
aliveConsumer(session->createConsumer(serviceQueue,ss.str())) ;
LOG4CXX_INFO(logger, "service prêt") ;
do
{
// Récupération prioritaire des messages de vie
message = aliveConsumer->receiveNoWait() ;
// si pas de message de vue, on se met en attente d'un autre
type de message
if (message == NULL)
{
// récupère un message de la file d'attente (bloque
si celle-ci est vide)
message =
consumer->receive(msi::constant::system::maxMessageWait) ;
}
> receiveNoWait never returns
> ---------------------------
>
> Key: AMQCPP-531
> URL: https://issues.apache.org/jira/browse/AMQCPP-531
> Project: ActiveMQ C++ Client
> Issue Type: Bug
> Affects Versions: 3.8.2
> Environment: AIX 6.1
> Compilateur XLC V12
> ActiveMQ-cpp buit with the following options : -qminimaltoc -q64 -qrtti=all
> Reporter: Vincent Giacomini
> Assignee: Timothy Bish
>
> Just built the last version 3.8.2 of activemq-cpp (SSL disabled)
> But my application doesn't work anymore.
> The reason : the consumer->ReceiveNoWait() method now never returns
> Works well in activemq-cpp 3.4.1....
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
