package tech.powerjob.remote.akka;
|
|
import akka.serialization.JSerializer;
|
import tech.powerjob.common.serialize.SerializerUtils;
|
|
/**
|
* Using custom serializers for akka-remote
|
* https://doc.akka.io/docs/akka/current/serialization.html
|
*
|
* @author tjq
|
* @since 2021/3/21
|
*/
|
public class PowerAkkaSerializer extends JSerializer {
|
|
@Override
|
public Object fromBinaryJava(byte[] bytes, Class<?> manifest) {
|
return SerializerUtils.deSerialized(bytes);
|
}
|
|
@Override
|
public int identifier() {
|
return 277777;
|
}
|
|
@Override
|
public byte[] toBinary(Object o) {
|
return SerializerUtils.serialize(o);
|
}
|
|
@Override
|
public boolean includeManifest() {
|
return false;
|
}
|
}
|
