类的使用
io.seata.core.protocol.RpcMessage

使用RpcMessage的程序包

程序包	说明
io.seata.core.protocol
io.seata.core.rpc
io.seata.core.rpc.netty

io.seata.core.protocol中RpcMessage的使用

返回RpcMessage的io.seata.core.protocol中的方法

限定符和类型	方法和说明
RpcMessage	MessageFuture.getRequestMessage() Gets request message.
RpcMessage	RpcMessage.setCodec(byte codec) Sets codec.
RpcMessage	RpcMessage.setCompressor(byte compressor) Sets compressor.
RpcMessage	RpcMessage.setHeadMap(Map<String,String> headMap) Sets head map.

参数类型为RpcMessage的io.seata.core.protocol中的方法

限定符和类型	方法和说明
void	MessageFuture.setRequestMessage(RpcMessage requestMessage) Sets request message.

io.seata.core.rpc中RpcMessage的使用

参数类型为RpcMessage的io.seata.core.rpc中的方法

限定符和类型	方法和说明
void	ServerMessageListener.onCheckMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx) On check message.
void	DefaultServerMessageListenerImpl.onCheckMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx)
void	ClientMessageListener.onMessage(RpcMessage request, String serverAddress) On message.
void	ServerMessageListener.onRegRmMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx, RegisterCheckAuthHandler checkAuthHandler) On reg rm message.
void	DefaultServerMessageListenerImpl.onRegRmMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx, RegisterCheckAuthHandler checkAuthHandler)
void	ServerMessageListener.onRegTmMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx, RegisterCheckAuthHandler checkAuthHandler) On reg tm message.
void	DefaultServerMessageListenerImpl.onRegTmMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx, RegisterCheckAuthHandler checkAuthHandler)
void	ServerMessageListener.onTrxMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx) On trx message.
void	DefaultServerMessageListenerImpl.onTrxMessage(RpcMessage request, io.netty.channel.ChannelHandlerContext ctx)
void	ServerMessageSender.sendResponse(RpcMessage request, io.netty.channel.Channel channel, Object msg) Send response.
void	ClientMessageSender.sendResponse(RpcMessage request, String serverAddress, Object msg) Send response.

io.seata.core.rpc.netty中RpcMessage的使用

类型参数类型为RpcMessage的io.seata.core.rpc.netty中的字段

限定符和类型	字段和说明
protected ConcurrentHashMap<String,BlockingQueue<RpcMessage>>	AbstractRpcRemoting.basketMap The Basket map.

参数类型为RpcMessage的io.seata.core.rpc.netty中的方法

限定符和类型	方法和说明
protected void	AbstractRpcRemoting.defaultSendResponse(RpcMessage request, io.netty.channel.Channel channel, Object msg) Default Send response.
void	RmMessageListener.onMessage(RpcMessage request, String serverAddress)
void	RpcServer.sendResponse(RpcMessage request, io.netty.channel.Channel channel, Object msg) Send response.
void	AbstractRpcRemotingClient.sendResponse(RpcMessage request, String serverAddress, Object msg)