gloduck / nettyrpc Goto Github PK

    public <T extends Serializable> byte[] encode(T obj) throws SerializationException {
        Kryo kryo = pool.borrow();
        byte[] bytes;
        try (ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); Output output = new Output(outputStream)){
            kryo.writeObject(output, obj);
            output.flush();
            bytes = outputStream.toByteArray();
        } catch (IOException e){
            throw new SerializationException(e);
        } finally {
            pool.release(kryo);
        }
        return bytes;
    }