svn commit: r430716 - in /incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq: TestSupport.java ZeroPrefetchConsumerTest.java

[jstrachan]

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");
     }
 
 }