- java.lang.Object
-
- org.redkale.mq.spi.MessageServlet
-
- org.redkale.mq.spi.HttpMessageServlet
-
- 所有已实现的接口:
MessageProcessor
public class HttpMessageServlet extends MessageServlet
一个Service对应一个MessageProcessor详情见: https://redkale.org
- 从以下版本开始:
- 2.1.0
- 作者:
- zhangjx
-
-
字段概要
-
从类继承的字段 org.redkale.mq.spi.MessageServlet
context, logger, messageClient, service, servlet, topic
-
-
构造器概要
构造器 构造器 说明 HttpMessageServlet(MessageClient messageClient, Context context, Service service, HttpServlet servlet, String topic)
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 protected Request
createRequest(Context context, MessageRecord message)
protected Response
createResponse(Context context, Request request)
protected void
onError(Response response, MessageRecord message, Throwable t)
-
从类继承的方法 org.redkale.mq.spi.MessageServlet
getContext, getService, getServlet, getTopic, process
-
-
-
-
构造器详细资料
-
HttpMessageServlet
public HttpMessageServlet(MessageClient messageClient, Context context, Service service, HttpServlet servlet, String topic)
-
-
方法详细资料
-
createRequest
protected Request createRequest(Context context, MessageRecord message)
- 指定者:
createRequest
在类中MessageServlet
-
createResponse
protected Response createResponse(Context context, Request request)
- 指定者:
createResponse
在类中MessageServlet
-
onError
protected void onError(Response response, MessageRecord message, Throwable t)
- 指定者:
onError
在类中MessageServlet
-
-