From bc9d999eb568719ad5950995af058cfb16af7d16 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=B5=85=E6=A2=A6?= <1101766085@qq.com>
Date: Wed, 12 Feb 2025 15:33:16 +0800
Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E7=AE=80=E5=8C=96=E6=9B=BF?=
 =?UTF-8?q?=E6=8D=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../config/JacksonMessageSerializer.java      | 40 -------------------
 .../config/MqttBrokerConfiguration.java       |  3 +-
 2 files changed, 2 insertions(+), 41 deletions(-)
 delete mode 100644 mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/JacksonMessageSerializer.java

diff --git a/mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/JacksonMessageSerializer.java b/mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/JacksonMessageSerializer.java
deleted file mode 100644
index 80670ed7..00000000
--- a/mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/JacksonMessageSerializer.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * Copyright (c) 2019-2029, Dreamlu 卢春梦 (596392912@qq.com & dreamlu.net).
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *   http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.dromara.mica.mqtt.broker.config;
-
-import net.dreamlu.mica.core.utils.JsonUtil;
-import org.dromara.mica.mqtt.core.server.model.Message;
-import org.dromara.mica.mqtt.core.server.serializer.IMessageSerializer;
-
-/**
- * jackson 消息序列化
- *
- * @author L.cm
- */
-public class JacksonMessageSerializer implements IMessageSerializer {
-
-	@Override
-	public byte[] serialize(Message message) {
-		return JsonUtil.toJsonAsBytes(message);
-	}
-
-	@Override
-	public Message deserialize(byte[] data) {
-		return JsonUtil.readValue(data, Message.class);
-	}
-
-}
diff --git a/mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/MqttBrokerConfiguration.java b/mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/MqttBrokerConfiguration.java
index 6033d1d3..8c578864 100644
--- a/mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/MqttBrokerConfiguration.java
+++ b/mica-mqtt-broker/src/main/java/org/dromara/mica/mqtt/broker/config/MqttBrokerConfiguration.java
@@ -25,6 +25,7 @@
 import org.dromara.mica.mqtt.core.server.dispatcher.IMqttMessageDispatcher;
 import org.dromara.mica.mqtt.core.server.event.IMqttConnectStatusListener;
 import org.dromara.mica.mqtt.core.server.serializer.IMessageSerializer;
+import org.dromara.mica.mqtt.core.server.serializer.JsonMessageSerializer;
 import org.dromara.mica.mqtt.core.server.store.IMqttMessageStore;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.annotation.Bean;
@@ -40,7 +41,7 @@ public class MqttBrokerConfiguration {
 
 	@Bean
 	public IMessageSerializer messageSerializer() {
-		return new JacksonMessageSerializer();
+		return new JsonMessageSerializer();
 	}
 
 	@Bean