diff --git a/src/org/redkale/mq/MessageProcessor.java b/src/org/redkale/mq/MessageProcessor.java
new file mode 100644
index 000000000..2c89bbe6d
--- /dev/null
+++ b/src/org/redkale/mq/MessageProcessor.java
@@ -0,0 +1,19 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package org.redkale.mq;
+
+/**
+ *
+ *
+ * <p>
+ * 详情见: https://redkale.org
+ *
+ * @author zhangjx
+ */
+public interface MessageProcessor {
+
+    public void process(MessageRecord req, MessageResponse response);
+}
diff --git a/src/org/redkale/mq/MessageResponse.java b/src/org/redkale/mq/MessageResponse.java
new file mode 100644
index 000000000..aab59cfb6
--- /dev/null
+++ b/src/org/redkale/mq/MessageResponse.java
@@ -0,0 +1,15 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package org.redkale.mq;
+
+/**
+ *
+ * @author zhangjx
+ */
+public interface MessageResponse {
+
+    public void finish(MessageRecord result);
+}