activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rakesh (JIRA)" <j...@apache.org>
Subject [jira] Created: (AMQCPP-188) ActiveMQ message consumer waiting for receive to complete is not closing...
Date Thu, 10 Jul 2008 06:32:00 GMT
ActiveMQ message consumer waiting for receive to complete is not closing...
---------------------------------------------------------------------------

                 Key: AMQCPP-188
                 URL: https://issues.apache.org/activemq/browse/AMQCPP-188
             Project: ActiveMQ C++ Client
          Issue Type: Bug
          Components: CMS Impl
    Affects Versions: 2.2
         Environment: Windows
            Reporter: Rakesh
            Assignee: Nathan Mittler


I have a created an application which creates a connection and consumers using ActiveMQ C++
Client, after running the application consumer is waiting for the recive to complete. when
we shutdown the application we close the connection, but close call of connection does not
notify all the consumers (who is waiting for the message to be recived). 
I have seen in the close method of ActiveMQConsumer after purging all the messages there is
no call to notifyAll on object unconsumedMessages because of which consumers waiting for the
receive does not does not come out of the wait call, which is causing our application not
to shutdown.
we modified the close call the notify all the consumers after purging all the unconsumed mesages
and our application is working fine.

Following is the changes that i have made in ActiveMQConsumer.cpp class
void ActiveMQConsumer::close(){
....
....
            // Purge all the pending messages
            try{
                purgeMessages();
            } catch ( ActiveMQException& ex ){
                if( !haveException ){
                    ex.setMark( __FILE__, __LINE__ );
                    error = ex;
                    haveException = true;
                }
            }



         //Start of additional code
         synchronized( &unconsumedMessages )
         {
                unconsumedMessages.notifyAll();
         }
         //End of additional code

....
....
}

can anyone let me know why this has not been done? I think this should be done. please explain
if I am missing something


-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message