svn commit: r416637 - in /incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool: properties/ReflectionUtil.java spi/ActiveMQPojoSPI.java

[aco]

Author: aco
Date: Fri Jun 23 01:42:49 2006
New Revision: 416637

URL: http://svn.apache.org/viewvc?rev=416637&view=rev
Log:
Fix configuration bug for factory and ActiveMQPojoSPI

Modified:
    
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/properties/ReflectionUtil.java
    
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/spi/ActiveMQPojoSPI.java

Modified: 
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/properties/ReflectionUtil.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/properties/ReflectionUtil.java?rev=416637&r1=416636&r2=416637&view=diff
==============================================================================
--- 
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/properties/ReflectionUtil.java
 (original)
+++ 
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/properties/ReflectionUtil.java
 Fri Jun 23 01:42:49 2006
@@ -36,11 +36,6 @@
     }
 
     public static void configureClass(Object obj, String key, String val) {
-        // Check if we will recognize the property first
-        if (obj instanceof ReflectionConfigurable && 
!((ReflectionConfigurable)obj).acceptConfig(key, val)) {
-            return;
-        }
-
         try {
             String debugInfo;
 
@@ -67,6 +62,11 @@
 
             // Property name
             String property = tokenizer.nextToken();
+
+            // Check if the target object will accept the settings
+            if (obj instanceof ReflectionConfigurable && 
!((ReflectionConfigurable)target).acceptConfig(property, val)) {
+                return;
+            }
 
             // Determine data type of property
             Class propertyType = getField(targetClass, property).getType();

Modified: 
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/spi/ActiveMQPojoSPI.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/spi/ActiveMQPojoSPI.java?rev=416637&r1=416636&r2=416637&view=diff
==============================================================================
--- 
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/spi/ActiveMQPojoSPI.java
 (original)
+++ 
incubator/activemq/trunk/tooling/maven-activemq-perf-plugin/src/main/java/org/apache/activemq/tool/spi/ActiveMQPojoSPI.java
 Fri Jun 23 01:42:49 2006
@@ -22,24 +22,24 @@
 import java.util.Properties;
 
 public class ActiveMQPojoSPI implements SPIConnectionFactory {
-    public static final String KEY_BROKER_URL        = "factory.brokerUrl";
-    public static final String KEY_USERNAME          = "factory.username";
-    public static final String KEY_PASSWORD          = "factory.password";
-    public static final String KEY_CLIENT_ID         = "factory.clientID";
+    public static final String KEY_BROKER_URL        = "brokerUrl";
+    public static final String KEY_USERNAME          = "username";
+    public static final String KEY_PASSWORD          = "password";
+    public static final String KEY_CLIENT_ID         = "clientID";
 
-    public static final String KEY_ASYNC_SEND        = "factory.asyncSend";
-    public static final String KEY_ASYNC_DISPATCH    = "factory.asyncDispatch";
-    public static final String KEY_ASYNC_SESSION     = "factory.asyncSession";
-    public static final String KEY_CLOSE_TIMEOUT     = "factory.closeTimeout";
-    public static final String KEY_COPY_MSG_ON_SEND  = "factory.copyMsgOnSend";
-    public static final String KEY_DISABLE_TIMESTAMP = 
"factory.disableTimestamp";
-    public static final String KEY_DEFER_OBJ_SERIAL  = 
"factory.deferObjSerial";
-    public static final String KEY_OPTIM_ACK         = "factory.optimAck";
-    public static final String KEY_OPTIM_DISPATCH    = "factory.optimDispatch";
-    public static final String KEY_PREFETCH_QUEUE    = "factory.prefetchQueue";
-    public static final String KEY_PREFETCH_TOPIC    = "factory.prefetchTopic";
-    public static final String KEY_USE_COMPRESSION   = 
"factory.useCompression";
-    public static final String KEY_USE_RETROACTIVE   = 
"factory.useRetroactive";
+    public static final String KEY_ASYNC_SEND        = "asyncSend";
+    public static final String KEY_ASYNC_DISPATCH    = "asyncDispatch";
+    public static final String KEY_ASYNC_SESSION     = "asyncSession";
+    public static final String KEY_CLOSE_TIMEOUT     = "closeTimeout";
+    public static final String KEY_COPY_MSG_ON_SEND  = "copyMsgOnSend";
+    public static final String KEY_DISABLE_TIMESTAMP = "disableTimestamp";
+    public static final String KEY_DEFER_OBJ_SERIAL  = "deferObjSerial";
+    public static final String KEY_OPTIM_ACK         = "optimAck";
+    public static final String KEY_OPTIM_DISPATCH    = "optimDispatch";
+    public static final String KEY_PREFETCH_QUEUE    = "prefetchQueue";
+    public static final String KEY_PREFETCH_TOPIC    = "prefetchTopic";
+    public static final String KEY_USE_COMPRESSION   = "useCompression";
+    public static final String KEY_USE_RETROACTIVE   = "useRetroactive";
 
     public ConnectionFactory createConnectionFactory(Properties settings) 
throws Exception {
         ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory();