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

apply patch for: https://issues.apache.org/jira/browse/AMQ-4306 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1444193 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-02-08 19:03:28 +00:00
parent 386b7bb844
commit 94b9d551b7
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-kahadb-store/src/test/java/org/apache/activemq/store/kahadb/disk/index/BTreeIndexTest.java
View File

@ -181,11 +181,11 @@ public class BTreeIndexTest extends IndexTestSupport {
index.visit(tx, new BTreeVisitor<String, Long>(){
@Override
public boolean isInterestedInKeysBetween(String first, String second) {
public boolean isInterestedInKeysBetween(String first, String second) {
return true;
}
@Override
public void visit(List<String> keys, List<Long> values) {
public void visit(List<String> keys, List<Long> values) {
}
});
@ -236,7 +236,7 @@ public class BTreeIndexTest extends IndexTestSupport {
}
}
@Test(timeout=300000)
@Test(timeout=900000)
public void testRandomAddRemove() throws Exception {
createPageFileAndIndex(1024);
@ -565,7 +565,7 @@ public class BTreeIndexTest extends IndexTestSupport {
final static HashSetStringMarshaller INSTANCE = new HashSetStringMarshaller();
@Override
public void writePayload(HashSet<String> object, DataOutput dataOut) throws IOException {
public void writePayload(HashSet<String> object, DataOutput dataOut) throws IOException {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream oout = new ObjectOutputStream(baos);
oout.writeObject(object);
@ -577,7 +577,7 @@ public class BTreeIndexTest extends IndexTestSupport {
}
@Override
public HashSet<String> readPayload(DataInput dataIn) throws IOException {
public HashSet<String> readPayload(DataInput dataIn) throws IOException {
int dataLen = dataIn.readInt();
byte[] data = new byte[dataLen];
dataIn.readFully(data);