修正ActiveMQ C++客户端(CMS)当服务器关闭程序无法退出问题

现在正用ActiveMQ C++客户端开发，发现有个问题，当开始连接ActiveMQ服务器成功后，成功发送数据后，此时ActiveMQ服务器停止，客户端无法退出，出现挂掉现象。

通过调试代码当客户端退出调用如下代码：

        try{
            if( producer != NULL ) delete producer;
        }catch ( CMSException& e ) { e.printStackTrace(); }
        producer = NULL;

        // Close open resources.
        try{
            if( session != NULL ) session->close();
            if( connection != NULL ) connection->close();
        }catch ( CMSException& e ) { e.printStackTrace(); }

        try{
            if( session != NULL ) delete session;
        }catch ( CMSException& e ) { e.printStackTrace(); }
        session = NULL;

        try{
            if( connection != NULL ) delete connection;
        }catch ( CMSException& e ) { e.printStackTrace(); }
        connection = NULL;

程序报异常，检查代码发现在ActiveMQSession.cpp中，delete producer会调用close方法，然后调用ActiveMQSession::disposeOf方法，而里面会调用this->connection->disposeOf( id );这个过程会发送指令到服务器，在服务器关闭后会抛异常，而没有调用session的this->producers.remove( id ); 在producer的析构函数中，会将所有异常捕获不往外抛，此时proceducer对象被顺利删除，在session的producers中并没有将此producer移除掉，而在session关闭时，会调用ActiveMQSession::close() 方法，在此方法中将所有的producer关掉，而此时会调用到被删除的producer，所以报错。

同理session对connection也有这个情况，在ActiveMQSession::close()方法中，会同样调用this->connection->disposeOf( this->sessionInfo->getSessionId() );让connectio移除session.

所以需要修改代码，在ActiveMQSession.cpp中增加如下代码

#ifdef HHESOCKET_ERROR
#define HHSOCKETERROR_START /
        try{ 

#define HHSOCKETERROR_END /
             } /
            catch(ActiveMQException& ex) { /
                const decaf::io::IOException* exception1 = dynamic_cast<const decaf::io::IOException*>(ex.getCause()); /
                if (NULL != exception1) { /
                    string data = exception1->getMessage(); /
                    if (NULL == strstr(data.c_str(), "decaf::net::SocketOutputStream::write")) /
                        throw ex; /
                } /
                else /
                    throw ex; /
            }
#endif

修改ActiveMQSession::close()方法将this->connection->disposeOf( this->sessionInfo->getSessionId() );改为如下代码：

#ifdef HHESOCKET_ERROR
        HHSOCKETERROR_START
#endif
        // Remove this session from the Broker.
        this->connection->disposeOf( this->sessionInfo->getSessionId() );
#ifdef HHESOCKET_ERROR
        HHSOCKETERROR_END
#endif

修改ActiveMQSession::disposeOf( Pointer<ProducerId> id )方法，将this->connection->disposeOf( id );改为如下代码：

#ifdef HHESOCKET_ERROR
                HHSOCKETERROR_START
#endif
                this->connection->disposeOf( id );
#ifdef HHESOCKET_ERROR
                HHSOCKETERROR_END
#endif

修改ActiveMQSession::disposeOf( Pointer<CustomerId> id )方法，将this->connection->disposeOf( id );也改为如上代码

在项目中添加HHESOCKET_ERROR预定义宏，重新编译activemq项目即可