diff --git a/mica-mqtt-client/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientCreator.java b/mica-mqtt-client/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientCreator.java
index 1a194975..bc08bba1 100644
--- a/mica-mqtt-client/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientCreator.java
+++ b/mica-mqtt-client/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientCreator.java
@@ -35,7 +35,6 @@
 
 import java.io.InputStream;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.ThreadPoolExecutor;
 import java.util.function.Consumer;
 
 /**
@@ -480,7 +479,7 @@ public MqttClientCreator groupExecutor(ExecutorService groupExecutor) {
 		return this;
 	}
 
-	public MqttClientCreator mqttExecutor(ThreadPoolExecutor mqttExecutor) {
+	public MqttClientCreator mqttExecutor(ExecutorService mqttExecutor) {
 		this.mqttExecutor = mqttExecutor;
 		return this;
 	}
diff --git a/pom.xml b/pom.xml
index 99c8af4c..8968483e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
 
     <properties>
         <!-- mica-mqtt version -->
-        <revision>2.2.5</revision>
+        <revision>2.2.5.1</revision>
         <!-- java version -->
         <java.version>1.8</java.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>