diff options
Diffstat (limited to 'zookeeper-server/src/test/java/org/apache/zookeeper/server/PrepRequestProcessorMetricsTest.java')
-rw-r--r-- | zookeeper-server/src/test/java/org/apache/zookeeper/server/PrepRequestProcessorMetricsTest.java | 10 |
1 files changed, 1 insertions, 9 deletions
diff --git a/zookeeper-server/src/test/java/org/apache/zookeeper/server/PrepRequestProcessorMetricsTest.java b/zookeeper-server/src/test/java/org/apache/zookeeper/server/PrepRequestProcessorMetricsTest.java index 062cae1f9..bfb0db5f3 100644 --- a/zookeeper-server/src/test/java/org/apache/zookeeper/server/PrepRequestProcessorMetricsTest.java +++ b/zookeeper-server/src/test/java/org/apache/zookeeper/server/PrepRequestProcessorMetricsTest.java @@ -29,15 +29,12 @@ import static org.mockito.Mockito.doAnswer; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.spy; import static org.mockito.Mockito.when; -import java.io.ByteArrayOutputStream; import java.io.IOException; -import java.nio.ByteBuffer; import java.util.HashSet; import java.util.Map; import java.util.Set; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; -import org.apache.jute.BinaryOutputArchive; import org.apache.jute.Record; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.WatchedEvent; @@ -94,12 +91,7 @@ public class PrepRequestProcessorMetricsTest extends ZKTestCase { } private Request createRequest(Record record, int opCode) throws IOException { - // encoding - ByteArrayOutputStream baos = new ByteArrayOutputStream(); - BinaryOutputArchive boa = BinaryOutputArchive.getArchive(baos); - record.serialize(boa, "request"); - baos.close(); - return new Request(null, 1L, 0, opCode, ByteBuffer.wrap(baos.toByteArray()), null); + return new Request(null, 1L, 0, opCode, RequestRecord.fromRecord(record), null); } private Request createRequest(String path, int opCode) throws IOException { |