[AMQCPP-532] Frequently deleting queue browser causes access violation

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.8.2
• Fix Version/s: 3.9.0

Environment

Windows

• Assignee: Timothy A. Bish
• Reporter: Andrei Gheorghe
• Created: 27/Jan/14 14:54
• Updated: 29/Jul/15 21:52
• Resolved: 29/Jul/15 21:52

Description

The following code should reproduce this issue :

#include <activemq/library/ActiveMQCPP.h>
#include <activemq/core/ActiveMQConnectionFactory.h>
#include <activemq/commands/ActiveMQQueue.h>

using namespace cms;

int main()
{
try
{
activemq::library::ActiveMQCPP::initializeLibrary();
activemq::core::ActiveMQConnectionFactory connectionFactory( "tcp://localhost:61616" );
auto connection = connectionFactory.createConnection();
connection->start();
auto session = connection->createSession( Session::SESSION_TRANSACTED );

activemq::commands::ActiveMQQueue queue( "testqueue" ); //sometimes it doesn't crash if the queue is empty so it should have atleast a message
while ( 1 )

{ auto queueBrowser = session->createBrowser( &queue, "" ); auto enumeration = queueBrowser->getEnumeration(); if ( enumeration->hasMoreMessages() ) auto message = enumeration->nextMessage(); delete queueBrowser; }

}
catch ( const std::exception& e )

{ std::string what = e.what(); //sometimes it throws an exception like "Monitor is still in use!" }

while ( 1 ) {} //wait, sometimes an activemq thread fails
}