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

Test updates, use a proper MessageId and add some logging so the level DB test errors are more obvious. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1503727 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-07-16 14:15:37 +00:00
parent 975b7819cf
commit f80071f65d
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-unit-tests/src/test/java/org/apache/activemq/broker/region/cursors/StoreQueueCursorNoDuplicateTest.java
View File

@ -31,6 +31,7 @@ import org.apache.activemq.command.MessageId;
import org.apache.activemq.store.MessageStore;
import org.apache.activemq.store.PersistenceAdapter;
import org.apache.activemq.usage.SystemUsage;
import org.mortbay.log.Log;
/**
* @author gtully
@ -41,12 +42,13 @@ public class StoreQueueCursorNoDuplicateTest extends TestCase {
+ StoreQueueCursorNoDuplicateTest.class.getSimpleName());
BrokerService brokerService;
final static String mesageIdRoot = "11111:22222:";
final static String mesageIdRoot = "11111:22222:0:";
final int messageBytesSize = 1024;
final String text = new String(new byte[messageBytesSize]);
protected int count = 6;
@Override
public void setUp() throws Exception {
brokerService = createBroker();
brokerService.setUseJmx(false);
@ -58,6 +60,7 @@ public class StoreQueueCursorNoDuplicateTest extends TestCase {
return new BrokerService();
}
@Override
public void tearDown() throws Exception {
brokerService.stop();
}
@ -103,8 +106,9 @@ public class StoreQueueCursorNoDuplicateTest extends TestCase {
MessageReference ref = underTest.next();
ref.decrementReferenceCount();
underTest.remove();
assertEquals(dequeueCount++, ref.getMessageId()
.getProducerSequenceId());
Log.info("Received message: {} with body: {}",
ref.getMessageId(), ((ActiveMQTextMessage)ref.getMessage()).getText());
assertEquals(dequeueCount++, ref.getMessageId().getProducerSequenceId());
}
underTest.release();
assertEquals(count, dequeueCount);