Skip to content

Commit

Permalink
do not use FQCN
Browse files Browse the repository at this point in the history
  • Loading branch information
eolivelli committed Jun 15, 2018
1 parent 9e07506 commit c24872c
Showing 1 changed file with 4 additions and 3 deletions.
Expand Up @@ -27,6 +27,7 @@
import java.util.EnumSet;
import org.apache.bookkeeper.client.api.DigestType;
import org.apache.bookkeeper.client.api.LedgerEntries;
import org.apache.bookkeeper.client.api.LedgerEntry;
import org.apache.bookkeeper.client.api.ReadHandle;
import org.apache.bookkeeper.client.api.WriteFlag;
import org.apache.bookkeeper.client.api.WriteHandle;
Expand Down Expand Up @@ -124,14 +125,14 @@ private void testClose(boolean force) throws Exception {

try (LedgerEntries entries = readLh.read(0, n - 1)) {
for (int i = 0; i < n; i++) {
org.apache.bookkeeper.client.api.LedgerEntry entry = entries.getEntry(i);
LedgerEntry entry = entries.getEntry(i);
assertEquals("entry-" + i, new String(entry.getEntryBytes()));
}
}

try (LedgerEntries entries = readLh.readUnconfirmed(0, n - 1)) {
for (int i = 0; i < n; i++) {
org.apache.bookkeeper.client.api.LedgerEntry entry = entries.getEntry(i);
LedgerEntry entry = entries.getEntry(i);
assertEquals("entry-" + i, new String(entry.getEntryBytes()));
}
}
Expand All @@ -148,7 +149,7 @@ private void testClose(boolean force) throws Exception {
// entry will be readable with readUnconfirmed
try (LedgerEntries entries = readLh.readUnconfirmed(0, n - 1)) {
for (int i = 0; i < n; i++) {
org.apache.bookkeeper.client.api.LedgerEntry entry = entries.getEntry(i);
LedgerEntry entry = entries.getEntry(i);
assertEquals("entry-" + i, new String(entry.getEntryBytes()));
}
}
Expand Down

0 comments on commit c24872c

Please sign in to comment.