From b746aa18593e21aa361e6ab3328ee171cefa3f45 Mon Sep 17 00:00:00 2001 From: tjq Date: Sat, 21 Jan 2023 11:05:24 +0800 Subject: [PATCH] feat: redefine PowerAkkaSerializer --- .../main/java/tech/powerjob/common/PowerSerializable.java | 8 -------- .../tech/powerjob/remote/akka}/PowerAkkaSerializer.java | 4 +++- .../src/main/resources/powerjob.akka.conf | 2 +- 3 files changed, 4 insertions(+), 10 deletions(-) rename {powerjob-common/src/main/java/tech/powerjob/common/serialize => powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka}/PowerAkkaSerializer.java (87%) diff --git a/powerjob-common/src/main/java/tech/powerjob/common/PowerSerializable.java b/powerjob-common/src/main/java/tech/powerjob/common/PowerSerializable.java index 48a59ab5..e8dd990f 100644 --- a/powerjob-common/src/main/java/tech/powerjob/common/PowerSerializable.java +++ b/powerjob-common/src/main/java/tech/powerjob/common/PowerSerializable.java @@ -9,12 +9,4 @@ import java.io.Serializable; * @since 2020/4/16 */ public interface PowerSerializable extends Serializable { - - /** - * request path for http or other protocol, like '/worker/stopInstance' - * @return null for non-http request object or no-null path for http request needed object - */ - default String path() { - return null; - } } diff --git a/powerjob-common/src/main/java/tech/powerjob/common/serialize/PowerAkkaSerializer.java b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/PowerAkkaSerializer.java similarity index 87% rename from powerjob-common/src/main/java/tech/powerjob/common/serialize/PowerAkkaSerializer.java rename to powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/PowerAkkaSerializer.java index 2f05dd6f..ba58b841 100644 --- a/powerjob-common/src/main/java/tech/powerjob/common/serialize/PowerAkkaSerializer.java +++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/PowerAkkaSerializer.java @@ -1,6 +1,7 @@ -package tech.powerjob.common.serialize; +package tech.powerjob.remote.akka; import akka.serialization.JSerializer; +import tech.powerjob.common.serialize.SerializerUtils; /** * Using custom serializers for akka-remote @@ -31,3 +32,4 @@ public class PowerAkkaSerializer extends JSerializer { return false; } } + diff --git a/powerjob-remote/powerjob-remote-impl-akka/src/main/resources/powerjob.akka.conf b/powerjob-remote/powerjob-remote-impl-akka/src/main/resources/powerjob.akka.conf index f34e043e..8bd7ab69 100644 --- a/powerjob-remote/powerjob-remote-impl-akka/src/main/resources/powerjob.akka.conf +++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/resources/powerjob.akka.conf @@ -9,7 +9,7 @@ akka { allow-java-serialization = off serializers { - power-serializer = "tech.powerjob.common.serialize.PowerAkkaSerializer" + power-serializer = "tech.powerjob.remote.akka.PowerAkkaSerializer" } serialization-bindings {