模块 org.redkale

程序包 org.redkale.mq.spi

类 SncpMessageServlet

java.lang.Object

org.redkale.mq.spi.MessageServlet

org.redkale.mq.spi.SncpMessageServlet

所有已实现的接口:

MessageProcessor

public class SncpMessageServlet
extends MessageServlet

一个Service对应一个MessageProcessor

详情见: https://redkale.org

从以下版本开始:

2.1.0

作者:

zhangjx

字段概要

从类继承的字段 org.redkale.mq.spi.MessageServlet

context, logger, messageClient, service, servlet, topic

构造器概要

构造器

构造器	说明
SncpMessageServlet(MessageClient messageClient, Context context, Service service, SncpServlet 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

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SncpMessageServlet

public SncpMessageServlet(MessageClient messageClient,
                          Context context,
                          Service service,
                          SncpServlet 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