AMQ5.1.0 - HELP: Correct way of retrieveing a DestinationSource

[shaf <sh...@gmail.com>]

Hello,


I have had some rather inconsistent results when trying to retrieve a list
of queues via the DestinationsSource.getQueues() method. I have an existing
connection object and try to retrieve the DestinationSource using
connection.getDestinationSource().getQueues() but it works correctly on my
laptop environment but doesn't work on servers where deployed. I have the
following code to test:


public final void testHasQueue( name ) 
{
	try
	{
		ActiveMQConnection connection =
ActiveMQConnectionFactory.createConnection("tcp://127.0.0.1:61616");
		connection.start();
		
		DestinationSource ds = new DestinationSource( connection );
			
		Set<ActiveMQQueue> q = ds.getQueues();
			
		Iterator i = q.iterator();
			
		while ( i.hasNext() )
		{
			ActiveMQQueue que = (ActiveMQQueue)i.next();
				
			System.out.println("Queue found: " + que.getPhysicalName() );

			if ( que.getPhysicalName().equals( name ) )
			{
				System.out.println("The queue " + que.getPhysicalName() + " exists!");
				exit;
			}
				
		}
			
		connection.stop();
		connection = null;
		ds = null;
	}
	catch (Exception e)
	{
		e.printStackTrace();
	}
		
}



-- 
View this message in context: http://www.nabble.com/AMQ5.1.0---HELP%3A-Correct-way-of-retrieveing-a-DestinationSource-tp18134728p18134728.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.