类 com.fr.cluster.engine.transport.context.ClusterMessage
的使用

使用ClusterMessage的程序包

程序包	说明
com.fr.cluster.engine.transport.context
com.fr.cluster.engine.transport.context.components	Created by juhaoyu on 2017/12/13.
com.fr.cluster.engine.transport.context.impl
com.fr.cluster.engine.transport.context.impl.adaptor

com.fr.cluster.engine.transport.context中ClusterMessage的使用

返回ClusterMessage的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
static ClusterMessage	ClusterMessage.nodeNotReady()
ClusterMessage	ClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 指定节点和接收者发送消息
static ClusterMessage	ClusterMessage.wrap(byte[] data)

返回变量类型为ClusterMessage的类型的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	ClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 对特定接受者广播消息

参数类型为ClusterMessage的com.fr.cluster.engine.transport.context中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	ClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 对特定接受者广播消息
void	ClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.CastCallback castCallback) 异步广播
void	ClusterMessageSender.Callback.done(ClusterMessage message)
ClusterMessage	ClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options) 指定节点和接收者发送消息
void	ClusterMessageSender.send(ClusterNode address, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.Callback callback) 异步发送

类型变量类型为ClusterMessage的com.fr.cluster.engine.transport.context中的方法参数

限定符和类型	方法和说明
void	ClusterMessageSender.CastCallback.done(java.util.Map<ClusterNode,ClusterMessage> messageMap)

com.fr.cluster.engine.transport.context.components中ClusterMessage的使用

返回ClusterMessage的com.fr.cluster.engine.transport.context.components中的方法

限定符和类型	方法和说明
ClusterMessage	MessageWrapper.unwrapMessage(T message) 将处理过的数据解封

参数类型为ClusterMessage的com.fr.cluster.engine.transport.context.components中的方法

限定符和类型	方法和说明
T	MessageWrapper.wrapMessage(ClusterMessageReceiver receiver, ClusterMessage message) 在发送是处理数据

com.fr.cluster.engine.transport.context.impl中ClusterMessage的使用

返回ClusterMessage的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
ClusterMessage	FineClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)
ClusterMessage	DefaultMessageDispatcher.unwrapMessage(com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage message)

返回变量类型为ClusterMessage的类型的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	FineClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)

参数类型为ClusterMessage的com.fr.cluster.engine.transport.context.impl中的方法

限定符和类型	方法和说明
java.util.Map<ClusterNode,ClusterMessage>	FineClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)
void	FineClusterMessageSender.cast(ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.CastCallback castCallback)
ClusterMessage	FineClusterMessageSender.send(ClusterNode node, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options)
void	FineClusterMessageSender.send(ClusterNode address, ClusterMessageReceiver receiver, ClusterMessage message, RequestOptions options, ClusterMessageSender.Callback callback)
com.fr.cluster.engine.transport.context.impl.DefaultMessageDispatcher.DistributableMessage	DefaultMessageDispatcher.wrapMessage(ClusterMessageReceiver receiver, ClusterMessage message)

com.fr.cluster.engine.transport.context.impl.adaptor中ClusterMessage的使用

返回ClusterMessage的com.fr.cluster.engine.transport.context.impl.adaptor中的方法

限定符和类型	方法和说明
ClusterMessage	RequestHandlerAdaptor.handle(Message msg)