Changed how serialization logging works

This commit is contained in:
nathan 2018-04-04 15:04:28 +02:00
parent 09ef44391e
commit 010ee8f679
1 changed files with 5 additions and 5 deletions

View File

@ -114,7 +114,7 @@ class Project<T extends Project<T>> {
public public
void write(final ByteBuf buffer, final Object message) { void write(final ByteBuf buffer, final Object message) {
final Output output = new Output(); final Output output = new Output();
writeFullClassAndObject(null, output, message); writeFullClassAndObject(output, message);
buffer.writeBytes(output.getBuffer()); buffer.writeBytes(output.getBuffer());
} }
@ -124,7 +124,7 @@ class Project<T extends Project<T>> {
final Input input = new Input(); final Input input = new Input();
buffer.readBytes(input.getBuffer()); buffer.readBytes(input.getBuffer());
final Object o = readFullClassAndObject(null, input); final Object o = readFullClassAndObject(input);
buffer.skipBytes(input.position()); buffer.skipBytes(input.position());
return o; return o;
@ -132,19 +132,19 @@ class Project<T extends Project<T>> {
@Override @Override
public public
void writeFullClassAndObject(final Logger logger, final Output output, final Object value) { void writeFullClassAndObject(final Output output, final Object value) {
kryo.writeClassAndObject(output, value); kryo.writeClassAndObject(output, value);
} }
@Override @Override
public public
Object readFullClassAndObject(final Logger logger, final Input input) throws IOException { Object readFullClassAndObject(final Input input) throws IOException {
return kryo.readClassAndObject(input); return kryo.readClassAndObject(input);
} }
@Override @Override
public public
void finishInit() { void finishInit(final Logger logger, final Logger writeLogger) {
} }
@Override @Override