activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r891007 - in /activemq/sandbox/activemq-apollo-actor/activemq-dispatcher: ./ src/main/java/org/apache/activemq/actor/ src/test/java/org/apache/activemq/actor/ src/test/java/org/apache/activemq/dispatch/
Date Tue, 15 Dec 2009 21:42:34 GMT
Author: chirino
Date: Tue Dec 15 21:42:34 2009
New Revision: 891007

URL: http://svn.apache.org/viewvc?rev=891007&view=rev
Log:
adding the start of an Asm based actor generator.


Added:
    activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/main/java/org/apache/activemq/actor/AsmActor.java
    activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/IPizzaService.java
    activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/OrderRunnable.java
    activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/PizzaServiceCustomProxy.java
Modified:
    activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/pom.xml
    activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/ActorBenchmark.java
    activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/dispatch/DispatchSystemTest.java

Modified: activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/pom.xml
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/pom.xml?rev=891007&r1=891006&r2=891007&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/pom.xml (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/pom.xml Tue Dec 15 21:42:34
2009
@@ -49,11 +49,17 @@
       <artifactId>log4j</artifactId>
       <scope>test</scope>
     </dependency>
+    
     <dependency>
     	<groupId>cglib</groupId>
     	<artifactId>cglib</artifactId>
     	<version>2.2</version>
     </dependency>
+    <dependency>
+      <groupId>asm</groupId>
+      <artifactId>asm-tree</artifactId>
+      <version>3.1</version>
+    </dependency>
     
   </dependencies>
 

Added: activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/main/java/org/apache/activemq/actor/AsmActor.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/main/java/org/apache/activemq/actor/AsmActor.java?rev=891007&view=auto
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/main/java/org/apache/activemq/actor/AsmActor.java
(added)
+++ activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/main/java/org/apache/activemq/actor/AsmActor.java
Tue Dec 15 21:42:34 2009
@@ -0,0 +1,304 @@
+package org.apache.activemq.actor;
+
+import java.lang.reflect.Constructor;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+
+import org.apache.activemq.dispatch.DispatchQueue;
+import org.objectweb.asm.ClassWriter;
+import org.objectweb.asm.FieldVisitor;
+import org.objectweb.asm.Label;
+import org.objectweb.asm.MethodVisitor;
+import org.objectweb.asm.Opcodes;
+import org.objectweb.asm.Type;
+
+import static org.objectweb.asm.ClassWriter.*;
+
+public class AsmActor implements Opcodes {
+
+    public static <T> T create(Class<T> interfaceClass, T target, DispatchQueue
queue) throws Exception {
+        return create(target.getClass().getClassLoader(), interfaceClass, target, queue);
+    }
+    
+    public static <T> T create(ClassLoader classLoader, Class<T> interfaceClass,
T target, DispatchQueue queue) throws Exception {
+        Class<T> proxyClass = getProxyClass(classLoader, interfaceClass);
+        Constructor<?> constructor = proxyClass.getConstructors()[0];
+        return proxyClass.cast(constructor.newInstance(new Object[]{target, queue}));
+    }
+    
+    @SuppressWarnings("unchecked")
+    private static <T> Class<T> getProxyClass(ClassLoader loader, Class<T>
interfaceClass) throws Exception {
+        String proxyName = proxyName(interfaceClass);
+        try {
+            return (Class<T>) loader.loadClass(proxyName);
+        } catch (ClassNotFoundException e) {
+            Generator generator = new Generator(loader, interfaceClass);
+            return generator.generate();
+        }
+    }
+
+    static private String proxyName(Class<?> clazz) {
+        return "org.apache.activemq.actor.generated."+clazz.getName();
+    }
+    
+    private static final class Generator<T> {
+        
+        private static final String RUNNABLE = "java/lang/Runnable";
+        private static final String OBJECT = "java/lang/Object";
+        private static final String DISPATCH_QUEUE = DispatchQueue.class.getName().replace('.','/');
+
+        private final ClassLoader loader;
+        private Method defineClassMethod;
+
+        private final Class<T> interfaceClass;
+        private String proxyName;
+        private String interfaceName;
+    
+        private Generator(ClassLoader loader, Class<T> interfaceClass) throws SecurityException,
NoSuchMethodException {
+            this.loader = loader;
+            this.interfaceClass = interfaceClass;
+            this.proxyName = proxyName(interfaceClass).replace('.', '/');
+            this.interfaceName = interfaceClass.getName().replace('.','/');
+            
+            defineClassMethod = java.lang.ClassLoader.class.getDeclaredMethod("defineClass",
new Class[] { String.class, byte[].class, int.class, int.class });
+            defineClassMethod.setAccessible(true);
+        }
+    
+        private Class<T> generate() throws Exception {
+            
+            // Define all the runnable classes used for each method.
+            Method[] methods = interfaceClass.getMethods();
+            for (int index = 0; index < methods.length; index++) {
+                String name = runnable(index).replace('/', '.');
+                byte[] clazzBytes = dumpRunnable(index, methods[index]);
+                defineClass(name, clazzBytes);
+            }
+            
+            String name = proxyName.replace('/', '.');
+            byte[] clazzBytes = dumpProxy(methods);
+            return defineClass(name, clazzBytes);
+        }
+        
+        @SuppressWarnings("unchecked")
+        private Class<T> defineClass(String name, byte[] classBytes) throws IllegalArgumentException,
IllegalAccessException, InvocationTargetException {
+            return (Class<T>) defineClassMethod.invoke(loader, new Object[] {name,
classBytes, 0, classBytes.length});
+        }
+        
+        public byte[] dumpProxy(Method[] methods) throws Exception {
+            ClassWriter cw = new ClassWriter(COMPUTE_FRAMES);
+            FieldVisitor fv;
+            MethodVisitor mv;
+            Label start, end;
+    
+            // example: 
+            cw.visit(V1_4, ACC_PUBLIC + ACC_SUPER, proxyName, null, OBJECT, new String[]
{ interfaceName });
+            {
+                // example:
+                fv = cw.visitField(ACC_PRIVATE + ACC_FINAL, "queue", sig(DISPATCH_QUEUE),
null, null);
+                fv.visitEnd();
+        
+                // example:
+                fv = cw.visitField(ACC_PRIVATE + ACC_FINAL, "target", sig(interfaceName),
null, null);
+                fv.visitEnd();
+        
+                // example: public PizzaServiceCustomProxy(IPizzaService target, DispatchQueue
queue)
+                mv = cw.visitMethod(ACC_PUBLIC, "<init>", "(" + sig(interfaceName)
+ sig(DISPATCH_QUEUE) + ")V", null, null);
+                {
+                    mv.visitCode();
+                    
+                    // example: super();
+                    start = new Label();
+                    mv.visitLabel(start);
+                    mv.visitVarInsn(ALOAD, 0);
+                    mv.visitMethodInsn(INVOKESPECIAL, OBJECT, "<init>", "()V");
+                    
+                    // example: queue=queue;
+                    mv.visitVarInsn(ALOAD, 0);
+                    mv.visitVarInsn(ALOAD, 2);
+                    mv.visitFieldInsn(PUTFIELD, proxyName, "queue", sig(DISPATCH_QUEUE));
+                    
+                    // example: this.target=target;
+                    mv.visitVarInsn(ALOAD, 0);
+                    mv.visitVarInsn(ALOAD, 1);
+                    mv.visitFieldInsn(PUTFIELD, proxyName, "target", sig(interfaceName));
+                    
+                    // example: return;
+                    mv.visitInsn(RETURN);
+                    
+                    end = new Label();
+                    mv.visitLabel(end);
+                    mv.visitLocalVariable("this", sig(proxyName), null, start, end, 0);
+                    mv.visitLocalVariable("target", sig(interfaceName), null, start, end,
1);
+                    mv.visitLocalVariable("queue", sig(DISPATCH_QUEUE), null, start, end,
2);
+                    mv.visitMaxs(2, 3);
+                }
+                mv.visitEnd();
+                
+                for (int index = 0; index < methods.length; index++) {
+                    Method method = methods[index];
+                    
+                    
+                    Class<?>[] params = method.getParameterTypes();
+                    
+                    // example: public void order(final long count)
+                    mv = cw.visitMethod(ACC_PUBLIC, method.getName(), "("+sig(params)+")V",
null, null); 
+                    {
+                        mv.visitCode();
+                        
+                        // example: queue.dispatchAsync(new OrderRunnable(target, count));
+                        start = new Label();
+                        mv.visitLabel(start);
+                        mv.visitVarInsn(ALOAD, 0);
+                        mv.visitFieldInsn(GETFIELD, proxyName, "queue", sig(DISPATCH_QUEUE));
+                        mv.visitTypeInsn(NEW, runnable(index));
+                        mv.visitInsn(DUP);
+                        mv.visitVarInsn(ALOAD, 0);
+                        mv.visitFieldInsn(GETFIELD, proxyName, "target", sig(interfaceName));
+                        
+                        for (int i = 0; i < params.length; i++) {
+                            // TODO: pick the right load
+                            mv.visitVarInsn(LLOAD, 1+i);
+                        }
+                        
+                        mv.visitMethodInsn(INVOKESPECIAL, runnable(index), "<init>",
"(" + sig(interfaceName) + sig(params) +")V");
+                        mv.visitMethodInsn(INVOKEINTERFACE, DISPATCH_QUEUE, "dispatchAsync",
"(" + sig(RUNNABLE) + ")V");
+                        
+                        // example: return;
+                        mv.visitInsn(RETURN);
+                        
+                        end = new Label();
+                        mv.visitLabel(end);
+                        mv.visitLocalVariable("this", sig(proxyName), null, start, end, 0);
+                        for (int i = 0; i < params.length; i++) {
+                            mv.visitLocalVariable("param"+i, sig(params[i]), null, start,
end, 1+i);
+                        }
+                        mv.visitMaxs(0, 0);
+                    }
+                    mv.visitEnd();
+                }
+            }
+            cw.visitEnd();
+    
+            return cw.toByteArray();
+        }
+    
+        public byte[] dumpRunnable(int index, Method method) throws Exception {
+    
+            ClassWriter cw = new ClassWriter(COMPUTE_FRAMES);
+            FieldVisitor fv;
+            MethodVisitor mv;
+            Label start, end;
+    
+            // example: final class OrderRunnable implements Runnable
+            cw.visit(V1_4, ACC_FINAL + ACC_SUPER, runnable(index), null, OBJECT, new String[]
{ RUNNABLE });
+            {
+    
+                // example: private final IPizzaService target;
+                fv = cw.visitField(ACC_PRIVATE + ACC_FINAL, "target", sig(interfaceName),
null, null);
+                fv.visitEnd();
+        
+                // TODO.. add field for each method parameter
+                // example: private final long count;
+                
+                Class<?>[] params = method.getParameterTypes();
+                for (int i = 0; i < params.length; i++) {
+                    fv = cw.visitField(ACC_PRIVATE + ACC_FINAL, "param"+i, sig(params[i]),
null, null);
+                    fv.visitEnd();
+                }
+        
+                // example: public OrderRunnable(IPizzaService target, long count) 
+                mv = cw.visitMethod(ACC_PUBLIC, "<init>", "(" + sig(interfaceName)+sig(params)+")V",
null, null);
+                {
+                    mv.visitCode();
+                    
+                    // example: super();
+                    start = new Label();
+                    mv.visitLabel(start);
+                    mv.visitVarInsn(ALOAD, 0);
+                    mv.visitMethodInsn(INVOKESPECIAL, OBJECT, "<init>", "()V");
+                    
+                    // example: this.target = target;
+                    mv.visitVarInsn(ALOAD, 0);
+                    mv.visitVarInsn(ALOAD, 1);
+                    mv.visitFieldInsn(PUTFIELD, runnable(index), "target", sig(interfaceName));
+                    
+                    // example: this.count = count;
+                    for (int i = 0; i < params.length; i++) {
+                        
+                        // TODO: figure out how to do the right loads. it varies with the
type.
+                        mv.visitVarInsn(ALOAD, 0);
+                        mv.visitVarInsn(LLOAD, 2+i);
+                        mv.visitFieldInsn(PUTFIELD, runnable(index), "param"+i, sig(params[i]));
+                        
+                    }
+                    
+                    // example: return;
+                    mv.visitInsn(RETURN);
+                    
+                    end = new Label();
+                    mv.visitLabel(end);
+                    mv.visitLocalVariable("this", sig(runnable(index)), null, start, end,
0);
+                    mv.visitLocalVariable("target", sig(interfaceName), null, start, end,
1);
+                    
+                    for (int i = 0; i < params.length; i++) {
+                        mv.visitLocalVariable("param"+i, sig(params[i]), null, start, end,
2+i);
+                    }
+                    mv.visitMaxs(0, 0);
+                }
+                mv.visitEnd();
+                
+                // example: public void run()
+                mv = cw.visitMethod(ACC_PUBLIC, "run", "()V", null, null);
+                {
+                    mv.visitCode();
+                    
+                    // example: target.order(count);
+                    start = new Label();
+                    mv.visitLabel(start);
+                    mv.visitVarInsn(ALOAD, 0);
+                    mv.visitFieldInsn(GETFIELD, runnable(index), "target", sig(interfaceName));
+                    
+                    for (int i = 0; i < params.length; i++) {
+                        mv.visitVarInsn(ALOAD, 0);
+                        mv.visitFieldInsn(GETFIELD, runnable(index), "param"+i, sig(params[i]));
+                    }
+                    
+                    mv.visitMethodInsn(INVOKEINTERFACE, interfaceName, method.getName(),
"("+sig(params)+")V");
+                    
+                    // example: return;
+                    mv.visitInsn(RETURN);
+            
+                    end = new Label();
+                    mv.visitLabel(end);
+                    mv.visitLocalVariable("this", sig(runnable(index)), null, start, end,
0);
+                    mv.visitMaxs(0, 0);
+                }
+                mv.visitEnd();
+            }
+            cw.visitEnd();
+    
+            return cw.toByteArray();
+        }
+
+
+        private String sig(Class<?>[] params) {
+            StringBuilder methodSig = new StringBuilder();
+            for (int i = 0; i < params.length; i++) {
+                methodSig.append(sig(params[i]));
+            }
+            return methodSig.toString();
+        }
+
+        private String sig(Class<?> clazz) {
+            return Type.getDescriptor(clazz);
+        }
+    
+        private String runnable(int index) {
+            return proxyName+"$method"+index;
+        }
+    
+        private String sig(String name) {
+            return "L"+name+";";
+        }
+    }
+}

Modified: activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/ActorBenchmark.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/ActorBenchmark.java?rev=891007&r1=891006&r2=891007&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/ActorBenchmark.java
(original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/ActorBenchmark.java
Tue Dec 15 21:42:34 2009
@@ -1,6 +1,5 @@
 package org.apache.activemq.actor;
 
-import org.apache.activemq.dispatch.DispatchQueue;
 import org.apache.activemq.dispatch.internal.AbstractSerialDispatchQueue;
 import org.junit.Test;
 
@@ -9,40 +8,57 @@
 public class ActorBenchmark {
 
     
-    public static class PizzaService
+    public static class PizzaService implements IPizzaService
     {
         long counter;
         
         @Message
-        public long order(long count)
+        public void order(long count)
         {
             counter += count;
-            return counter;
         }
     }
     
+//    @Test
+    public void benchmarkCGLibProxy() throws Exception {
+        String name = "cglib proxy";
+        PizzaService service = new PizzaService();
+        IPizzaService proxy = Actor.create(service, createQueue());
+        benchmark(name, service, proxy);
+    }
+
+    @Test
+    public void benchmarkCustomProxy() throws Exception {
+        String name = "custom proxy";
+        PizzaService service = new PizzaService();
+        IPizzaService proxy = new PizzaServiceCustomProxy(service, createQueue());
+        benchmark(name, service, proxy);
+    }
     
     @Test
-    public void benchmark() throws Exception {
-        
-        String name = "default actor";
+    public void benchmarkAsmProxy() throws Exception {
+        String name = "asm proxy";
         PizzaService service = new PizzaService();
-        
-        // Directly execute the requests...
-        DispatchQueue queue = new AbstractSerialDispatchQueue("") {
+        IPizzaService proxy = AsmActor.create(IPizzaService.class, service, createQueue());
+        benchmark(name, service, proxy);
+    }
+
+    private AbstractSerialDispatchQueue createQueue() {
+        return new AbstractSerialDispatchQueue("mock queue") {
             public void dispatchAsync(Runnable runnable) {
                 runnable.run();
             }
         };
-        
-        PizzaService proxy = Actor.create(service, queue);
+    }
 
+    private void benchmark(String name, PizzaService service, IPizzaService proxy) throws
Exception {
         // warm it up..
         benchmark(proxy, 1000*1000);
         if( service.counter == 0)
             throw new Exception();
         
-        int iterations = 1000*1000*1000;
+        int iterations = 1000*1000*100;
+        
         long start = System.nanoTime();
         benchmark(proxy, iterations);
         long end = System.nanoTime();
@@ -56,7 +72,7 @@
     }
 
 
-    private void benchmark(PizzaService proxy, int iterations) {
+    private void benchmark(IPizzaService proxy, int iterations) {
         for( int i=0; i < iterations; i++ ) {
             proxy.order(1);
         }

Added: activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/IPizzaService.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/IPizzaService.java?rev=891007&view=auto
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/IPizzaService.java
(added)
+++ activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/IPizzaService.java
Tue Dec 15 21:42:34 2009
@@ -0,0 +1,23 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.activemq.actor;
+
+public interface IPizzaService {
+    @Message
+    public void order(long count);
+}
\ No newline at end of file

Added: activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/OrderRunnable.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/OrderRunnable.java?rev=891007&view=auto
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/OrderRunnable.java
(added)
+++ activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/OrderRunnable.java
Tue Dec 15 21:42:34 2009
@@ -0,0 +1,33 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.activemq.actor;
+
+final class OrderRunnable implements Runnable {
+
+    private final IPizzaService target;
+    private final long count;
+
+    public OrderRunnable(IPizzaService target, long count) {
+        this.target = target;
+        this.count = count;
+    }
+
+    public void run() {
+        target.order(count);
+    }
+}
\ No newline at end of file

Added: activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/PizzaServiceCustomProxy.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/PizzaServiceCustomProxy.java?rev=891007&view=auto
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/PizzaServiceCustomProxy.java
(added)
+++ activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/actor/PizzaServiceCustomProxy.java
Tue Dec 15 21:42:34 2009
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.activemq.actor;
+
+import org.apache.activemq.dispatch.DispatchQueue;
+
+public class PizzaServiceCustomProxy implements IPizzaService {
+    private final DispatchQueue queue;
+    private final IPizzaService target;
+    
+    public PizzaServiceCustomProxy(IPizzaService target, DispatchQueue queue) {
+        this.queue = queue;
+        this.target=target;
+    }
+
+    public void order(final long count) {
+        queue.dispatchAsync(new OrderRunnable(target, count));
+    }
+    
+}
\ No newline at end of file

Modified: activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/dispatch/DispatchSystemTest.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/dispatch/DispatchSystemTest.java?rev=891007&r1=891006&r2=891007&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/dispatch/DispatchSystemTest.java
(original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-dispatcher/src/test/java/org/apache/activemq/dispatch/DispatchSystemTest.java
Tue Dec 15 21:42:34 2009
@@ -81,9 +81,10 @@
                 }
             }
         };
-        for (int i = 0; i < 1000; i++) {
-            queue.dispatchAsync(task);
-        }
+//        for (int i = 0; i < 1000; i++) {
+//        queue.dispatchAsync(task);
+//        }
+        queue.dispatchAsync(task);
         counter.await();
     }
     



Mime
View raw message