diff --git a/common/pom.xml b/common/pom.xml
index f3fad16389eaeb6e922d5f7b813db13df617a8b8..684b4135bfb91bfab6950218bd35aa69996821ae 100644
--- a/common/pom.xml
+++ b/common/pom.xml
@@ -54,4 +54,5 @@
snakeyaml
+
diff --git a/mqtt/src/main/java/org/apache/rocketmq/mqtt/exception/MqttRuntimeException.java b/mqtt/src/main/java/org/apache/rocketmq/mqtt/exception/MqttRuntimeException.java
new file mode 100644
index 0000000000000000000000000000000000000000..17b9b3592baee659e52806ded9740df134323add
--- /dev/null
+++ b/mqtt/src/main/java/org/apache/rocketmq/mqtt/exception/MqttRuntimeException.java
@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.rocketmq.mqtt.exception;
+
+public class MqttRuntimeException extends RuntimeException {
+
+ public MqttRuntimeException(String message) {
+ super(message);
+ }
+}
diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/EncodeDecodeDispatcher.java b/remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/EncodeDecodeDispatcher.java
index 3415e3a22c72f859ecc74e05e3e0ca35db1f59fa..33313abe21ba427752b81ef1330ffb3831fc4516 100644
--- a/remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/EncodeDecodeDispatcher.java
+++ b/remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/dispatcher/EncodeDecodeDispatcher.java
@@ -38,7 +38,7 @@ public class EncodeDecodeDispatcher {
encodeDecodeDispatcher.put(MqttMessageType.SUBACK, new MqttSubackEncodeDecode());
encodeDecodeDispatcher.put(MqttMessageType.UNSUBSCRIBE, new MqttUnSubscribeEncodeDecode());
encodeDecodeDispatcher.put(MqttMessageType.UNSUBACK, new MqttUnSubackEncodeDecode());
- encodeDecodeDispatcher.put(MqttMessageType.PINGREQ, new MqttPingReqEncodeDecode() );
+ encodeDecodeDispatcher.put(MqttMessageType.PINGREQ, new MqttPingReqEncodeDecode());
encodeDecodeDispatcher.put(MqttMessageType.PINGRESP, new MqttPingRespEncodeDecode());
}
diff --git a/store/pom.xml b/store/pom.xml
index 13e3b7d59008a8aab633e26585ea807c598367f5..d90e7fbda26dccbd647aaad60a70f3c7363f7f1c 100644
--- a/store/pom.xml
+++ b/store/pom.xml
@@ -31,7 +31,7 @@
io.openmessaging.storage
dledger
- 0.1-SNAPSHOT
+ 0.2-SNAPSHOT
org.apache.rocketmq