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);
+}

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);
+}