Author: sebb Date: Thu Dec 10 22:41:01 2009 New Revision: 889447 URL: http://svn.apache.org/viewvc?rev=889447&view=rev Log: Always return a valid topic connection
Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/ConnectionFactory.java Modified: jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/ConnectionFactory.java URL: http://svn.apache.org/viewvc/jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/ConnectionFactory.java?rev=889447&r1=889446&r2=889447&view=diff ============================================================================== --- jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/ConnectionFactory.java (original) +++ jakarta/jmeter/trunk/src/protocol/jms/org/apache/jmeter/protocol/jms/client/ConnectionFactory.java Thu Dec 10 22:41:01 2009 @@ -148,15 +148,17 @@ return qfactory; } - public static synchronized TopicConnection getTopicConnection() { + /** + * Use the factory to create a topic connection. + * + * @return the connection + * @throws JMSException if the factory is null or the create() method fails + */ + public static synchronized TopicConnection getTopicConnection() throws JMSException { if (factory != null) { - try { - return factory.createTopicConnection(); - } catch (JMSException e) { - log.error(e.getMessage()); - } + return factory.createTopicConnection(); } - return null; + throw new JMSException("Factory has not been initialised"); } public static synchronized QueueConnection getQueueConnection(Context ctx, String queueConn) { --------------------------------------------------------------------- To unsubscribe, e-mail: jmeter-dev-unsubscr...@jakarta.apache.org For additional commands, e-mail: jmeter-dev-h...@jakarta.apache.org