类的使用
org.redkale.mq.spi.MessageRecord

使用MessageRecord的程序包

程序包	说明
org.redkale.mq.spi

org.redkale.mq.spi中MessageRecord的使用

声明为MessageRecord的org.redkale.mq.spi中的字段

修饰符和类型	字段	说明
protected MessageRecord	HttpMessageRequest.message
protected MessageRecord	HttpMessageResponse.message
protected MessageRecord	MessageRespFuture.message
protected MessageRecord	SncpMessageRequest.message
protected MessageRecord	SncpMessageResponse.message

类型参数类型为MessageRecord的org.redkale.mq.spi中的字段

修饰符和类型	字段	说明
protected CompletableFuture<MessageRecord>	MessageRespFuture.future
protected MessageCoder<MessageRecord>	MessageAgent.messageRecordCoder

返回MessageRecord的org.redkale.mq.spi中的方法

修饰符和类型	方法	说明
MessageRecord	MessageRecord.content(byte[] content)
MessageRecord	MessageRecord.contentString(String content)
MessageRecord	MessageClient.createMessageRecord(byte ctype, String topic, String respTopic, byte[] content)
MessageRecord	MessageClient.createMessageRecord(byte ctype, String topic, String respTopic, String traceid, byte[] content)
MessageRecord	MessageClient.createMessageRecord(long seqid, byte ctype, String topic, String respTopic, byte[] content)
MessageRecord	MessageClient.createMessageRecord(long seqid, byte ctype, String topic, String respTopic, String traceid, byte[] content)
MessageRecord	MessageRecord.createTime(long createtime)
MessageRecord	MessageRecordSerializer.decode(byte[] data)
<T> MessageRecord	MessageRecord.encodeContent(MessageCoder<T> coder, T data)
MessageRecord	MessageRecord.flag(int flag)
MessageRecord	MessageRecord.groupid(String groupid)
MessageRecord	MessageRecord.localActionName(String actionName)
MessageRecord	MessageRecord.localParams(Object[] params)
MessageRecord	MessageRecord.respTopic(String resptopic)
MessageRecord	MessageRecord.topic(String topic)
MessageRecord	MessageRecord.traceid(String traceid)
MessageRecord	MessageRecord.userid(Serializable userid)
MessageRecord	MessageRecord.version(int version)

返回变量类型为MessageRecord的类型的org.redkale.mq.spi中的方法

修饰符和类型	方法	说明
MessageCoder<MessageRecord>	MessageClient.getClientMessageCoder()
CompletableFuture<MessageRecord>	MessageRespFuture.getFuture()
MessageCoder<MessageRecord>	MessageAgent.getMessageRecordCoder()
CompletableFuture<MessageRecord>	MessageClient.sendMessage(MessageRecord message)

参数类型为MessageRecord的org.redkale.mq.spi中的方法

修饰符和类型	方法	说明
abstract CompletableFuture<Void>	MessageClientProducer.apply(MessageRecord message)
protected Request	HttpMessageServlet.createRequest(Context context, MessageRecord message)
protected abstract Request	MessageServlet.createRequest(Context context, MessageRecord message)
protected Request	SncpMessageServlet.createRequest(Context context, MessageRecord message)
byte[]	MessageRecordSerializer.encode(MessageRecord data)
static void	HttpMessageResponse.finishHttpResult(boolean finest, Convert respConvert, Type type, MessageRecord msg, MessageClient messageClient, String respTopic, HttpResult result)
protected void	HttpMessageServlet.onError(Response response, MessageRecord message, Throwable t)
protected abstract void	MessageServlet.onError(Response response, MessageRecord message, Throwable t)
protected void	SncpMessageServlet.onError(Response response, MessageRecord message, Throwable t)
protected HttpMessageRequest	HttpMessageRequest.prepare(MessageRecord message)
void	HttpMessageResponse.prepare(MessageRecord message)
void	MessageClient.process(MessageRecord msg, long time)
void	MessageClientConsumer.process(MessageRecord message, long time)
void	MessageProcessor.process(MessageRecord msg, long time)
void	MessageRespProcessor.process(MessageRecord msg, long time)
void	MessageServlet.process(MessageRecord message, long time)
CompletableFuture<Void>	MessageClient.produceMessage(MessageRecord message)
CompletableFuture<MessageRecord>	MessageClient.sendMessage(MessageRecord message)

参数类型为MessageRecord的org.redkale.mq.spi中的构造器

构造器	说明
HttpMessageRequest(HttpContext context, MessageRecord message)
MessageRespFuture(MessageClient messageClient, CompletableFuture<MessageRecord> future, MessageRecord message)
SncpMessageRequest(SncpContext context, MessageRecord message)

类型变量类型为MessageRecord的org.redkale.mq.spi中的构造器参数

构造器	说明
MessageRespFuture(MessageClient messageClient, CompletableFuture<MessageRecord> future, MessageRecord message)