From adb0dc596383ed9652b179c388cd89ed029e59af Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Fri, 29 May 2020 11:15:56 +0800 Subject: [PATCH] --- src/org/redkale/mq/MessageProcessor.java | 19 +++++++++++++++++++ src/org/redkale/mq/MessageResponse.java | 15 +++++++++++++++ 2 files changed, 34 insertions(+) create mode 100644 src/org/redkale/mq/MessageProcessor.java create mode 100644 src/org/redkale/mq/MessageResponse.java 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; + +/** + * + * + *

+ * 详情见: 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); +}