com.fr.cluster.engine.transport.context.components

接口 ClusterMessageDispatcher<T extends java.io.Serializable>

所有超级接口:

MessageWrapper<T>

所有已知实现类:

DefaultMessageDispatcher

public interface ClusterMessageDispatcher<T extends java.io.Serializable>
extends MessageWrapper<T>

Created by juhaoyu on 2017/12/13. 消息分发器 1、发送时，将ClusterMessage进行封装，使器具备在其他节点中能找到对应receiver的数据 2、接收时，根据发送时封装的数据，找到正确的receiver

方法概要

方法

限定符和类型	方法和说明
ClusterMessageReceiver	chooseReceiver(T message, ClusterMessageReceiverRepo receiverRepo) 选择出正确的Receiver

从接口继承的方法 com.fr.cluster.engine.transport.context.components.MessageWrapper

unwrapMessage, wrapMessage

方法详细资料

chooseReceiver

ClusterMessageReceiver chooseReceiver(T message,
                                    ClusterMessageReceiverRepo receiverRepo)

选择出正确的Receiver