activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r430716 - in /incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq: TestSupport.java ZeroPrefetchConsumerTest.java
Date Fri, 11 Aug 2006 08:00:03 GMT
Author: jstrachan
Date: Fri Aug 11 01:00:03 2006
New Revision: 430716

URL: http://svn.apache.org/viewvc?rev=430716&view=rev
Log:
modified test case to use TCP to force marshalling of the MesagePull command to check thats
working

Modified:
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java?rev=430716&r1=430715&r2=430716&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java
Fri Aug 11 01:00:03 2006
@@ -68,9 +68,17 @@
     }
 
     protected Destination createDestination() {
-        return createDestination(getClass().getName() + "." + getName());
+        return createDestination(getDestinationString());
     }
 
+    /**
+     * Returns the name of the destination used in this test case
+     */
+    protected String getDestinationString() {
+        return getClass().getName() + "." + getName();
+    }
+    
+    
     /**
      * @param messsage
      * @param firstSet

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java?rev=430716&r1=430715&r2=430716&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java
Fri Aug 11 01:00:03 2006
@@ -34,7 +34,7 @@
  * 
  * @version $Revision$
  */
-public class ZeroPrefetchConsumerTest extends TestSupport {
+public class ZeroPrefetchConsumerTest extends EmbeddedBrokerTestSupport {
 
     private static final Log log = LogFactory.getLog(ZeroPrefetchConsumerTest.class);
 
@@ -68,7 +68,7 @@
     }
 
     protected void setUp() throws Exception {
-        topic = false;
+        bindAddress = "tcp://localhost:61616";
         super.setUp();
 
         connection = createConnection();
@@ -82,7 +82,7 @@
     }
 
     protected Queue createQueue() {
-        return new ActiveMQQueue(getClass().getName() + "." + getName() + "?consumer.prefetchSize=0");
+        return new ActiveMQQueue(getDestinationString() + "?consumer.prefetchSize=0");
     }
 
 }



Mime
View raw message