diff --git a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/core/BaseRabbiMqHandler.java b/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/core/BaseRabbiMqHandler.java
index 3b3aca59..014c9f67 100644
--- a/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/core/BaseRabbiMqHandler.java
+++ b/jero-boot/jero-boot-starter/jero-boot-starter-rabbitmq/src/main/java/com/jero/boot/starter/rabbitmq/core/BaseRabbiMqHandler.java
@@ -12,7 +12,7 @@ public class BaseRabbiMqHandler<T> {
 
     private String token= UserTokenContext.getToken();
 
-    public void onMessage(T t, Long deliveryTag, Channel channel, MqListener mqListener) {
+    public void onMessage(T t, Long deliveryTag, Channel channel, MqListener<T> mqListener) {
         try {
             UserTokenContext.setToken(token);
             mqListener.handler(t, channel);