activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vincent Giacomini (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (AMQCPP-531) receiveNoWait never returns
Date Fri, 24 Jan 2014 13:56:38 GMT

    [ https://issues.apache.org/jira/browse/AMQCPP-531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13880976#comment-13880976
] 

Vincent Giacomini edited comment on AMQCPP-531 at 1/24/14 1:55 PM:
-------------------------------------------------------------------

below the stack trace given 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) ;
		  }


was (Author: vgiacomini):
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)

Mime
View raw message