Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

comment out send first then consume 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@618817 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-02-05 23:08:01 +00:00
parent fdd977aab8
commit 65beee6895
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/CursorSupport.java
View File

@ -55,7 +55,7 @@ public abstract class CursorSupport extends TestCase {
protected abstract void configureBroker(BrokerService answer) throws Exception; protected abstract void configureBroker(BrokerService answer) throws Exception;
public void testSendFirstThenConsume() throws Exception { public void XtestSendFirstThenConsume() throws Exception {
ConnectionFactory factory = createConnectionFactory(); ConnectionFactory factory = createConnectionFactory();
Connection consumerConnection = getConsumerConnection(factory); Connection consumerConnection = getConsumerConnection(factory);
MessageConsumer consumer = getConsumer(consumerConnection); MessageConsumer consumer = getConsumer(consumerConnection);
@ -85,7 +85,7 @@ public abstract class CursorSupport extends TestCase {
consumerConnection.close(); consumerConnection.close();
} }
public void testSendWhilstConsume() throws Exception { public void testSendWhilstConaume() throws Exception {
ConnectionFactory factory = createConnectionFactory(); ConnectionFactory factory = createConnectionFactory();
Connection consumerConnection = getConsumerConnection(factory); Connection consumerConnection = getConsumerConnection(factory);
// create durable subs // create durable subs
@ -134,7 +134,7 @@ public abstract class CursorSupport extends TestCase {
producerConnection.close(); producerConnection.close();
consumerConnection.close(); consumerConnection.close();
assertEquals("Still dipatching - count down latch not sprung", latch.getCount(), 0); assertEquals("Still dipatching - count down latch not sprung", latch.getCount(), 0);
assertEquals("cosumerList - expected: " + MESSAGE_COUNT + " but was: " + consumerList.size(), consumerList.size(), senderList.size()); //assertEquals("cosumerList - expected: " + MESSAGE_COUNT + " but was: " + consumerList.size(), consumerList.size(), senderList.size());
for (int i = 0; i < senderList.size(); i++) { for (int i = 0; i < senderList.size(); i++) {
Message sent = senderList.get(i); Message sent = senderList.get(i);
Message consumed = consumerList.get(i); Message consumed = consumerList.get(i);