Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

modified test case to use TCP to force marshalling of the MesagePull command to check thats working

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@430716 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-08-11 08:00:03 +00:00
parent c26d8a9d0d
commit fb5a3730db
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-core/src/test/java/org/apache/activemq/TestSupport.java
View File

@ -68,9 +68,17 @@ public class TestSupport extends TestCase {
}
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

6
activemq-core/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java
View File

@ -34,7 +34,7 @@ import javax.jms.Session;
*
* @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 @@ public class ZeroPrefetchConsumerTest extends TestSupport {
}
protected void setUp() throws Exception {
topic = false;
bindAddress = "tcp://localhost:61616";
super.setUp();
connection = createConnection();
@ -82,7 +82,7 @@ public class ZeroPrefetchConsumerTest extends TestSupport {
}
protected Queue createQueue() {
return new ActiveMQQueue(getClass().getName() + "." + getName() + "?consumer.prefetchSize=0");
return new ActiveMQQueue(getDestinationString() + "?consumer.prefetchSize=0");
}
}