gistfile1.java

@Test
    public void shouldSerializeObject2() throws Exception {

        TraversalCounterMessage traverser = new TraversalCounterMessage();
        traverser.setCounter(10l);
        KryoWritable writable = new KryoWritable<>(traverser);

        final ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        final DataOutput out = new DataOutputStream(outputStream);
        writable.write(out);


        final byte[] objectBytes = new byte[outputStream.size()];
        for (int i = 0; i < outputStream.size(); i++) {
            objectBytes[i] = outputStream.toByteArray()[i];
        }
        final DataInput in = new DataInputStream(new ByteArrayInputStream(objectBytes));
        writable = new KryoWritable<>();
        writable.readFields(in);
        //assertEquals(writable.get(), "marko");


    }