You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by db...@apache.org on 2008/01/31 21:55:00 UTC
svn commit: r617235 -
/openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/OpenEjbBrokerFactory.java
Author: dblevins
Date: Thu Jan 31 12:54:57 2008
New Revision: 617235
URL: http://svn.apache.org/viewvc?rev=617235&view=rev
Log:
reformatted
Modified:
openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/OpenEjbBrokerFactory.java
Modified: openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/OpenEjbBrokerFactory.java
URL: http://svn.apache.org/viewvc/openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/OpenEjbBrokerFactory.java?rev=617235&r1=617234&r2=617235&view=diff
==============================================================================
--- openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/OpenEjbBrokerFactory.java (original)
+++ openejb/trunk/openejb3/container/openejb-core/src/main/java/org/apache/openejb/resource/activemq/OpenEjbBrokerFactory.java Thu Jan 31 12:54:57 2008
@@ -17,19 +17,19 @@
*/
package org.apache.openejb.resource.activemq;
-import java.net.URI;
-import java.util.Map;
-import java.util.Properties;
-import javax.naming.Context;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
-import javax.sql.DataSource;
-
import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.store.jdbc.JDBCPersistenceAdapter;
import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+import javax.sql.DataSource;
+import java.net.URI;
+import java.util.Map;
+import java.util.Properties;
+
public class OpenEjbBrokerFactory implements BrokerFactory.BrokerFactoryHandler {
private static final ThreadLocal<Properties> threadProperties = new ThreadLocal<Properties>();
@@ -42,12 +42,12 @@
BrokerService broker = BrokerFactory.createBroker(uri);
Properties properties = getLowerCaseProperties();
-
+
Object value = properties.get("datasource");
if (value instanceof String && value.toString().length() == 0) {
value = null;
}
-
+
if (value != null) {
DataSource dataSource;
if (value instanceof DataSource) {