diff --git a/router/java/src/net/i2p/router/transport/VMCommSystem.java b/router/java/src/net/i2p/router/transport/VMCommSystem.java index 11e7bc1efc4380ebf12c871c1fd3ebab20a8fbce..2e5426f08418aa86b39af20efbbf12fedd46c7ff 100644 --- a/router/java/src/net/i2p/router/transport/VMCommSystem.java +++ b/router/java/src/net/i2p/router/transport/VMCommSystem.java @@ -1,6 +1,5 @@ package net.i2p.router.transport; -import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.OutputStream; import java.io.Writer; @@ -110,7 +109,7 @@ public class VMCommSystem extends CommSystemFacade { public void runJob() { I2NPMessageHandler handler = new I2NPMessageHandler(_ctx); try { - I2NPMessage msg = handler.readMessage(new ByteArrayInputStream(_msg)); + I2NPMessage msg = handler.readMessage(_msg); int size = _msg.length; _ctx.profileManager().messageReceived(_from, "vm", 1, size); _ctx.statManager().addRateData("transport.receiveMessageSize", size, 1);