com.fr.cluster.engine.transport.context

接口 ClusterMessageSender

所有已知实现类:

FineClusterMessageSender

public interface ClusterMessageSender

Created by juhaoyu on 2017/12/13. 提供对某个receiver的请求 集群环境中的应用不止一个，请求时，不仅需要指定节点，还需要指定目的节点中的某个应用

嵌套类概要

嵌套类

限定符和类型	接口和说明
static interface	ClusterMessageSender.Callback 异步发送完成回调
static interface	ClusterMessageSender.CastCallback 广播完成回调

方法概要

方法

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

方法详细资料

send

ClusterMessage send(ClusterNode node,
                  ClusterMessageReceiver receiver,
                  ClusterMessage message,
                  RequestOptions options)
                    throws java.lang.Exception

指定节点和接收者发送消息

抛出:

java.lang.Exception

cast

java.util.Map<ClusterNode,ClusterMessage> cast(ClusterMessageReceiver receiver,
                                             ClusterMessage message,
                                             RequestOptions options)
                                               throws java.lang.Exception

对特定接受者广播消息

抛出:

java.lang.Exception

send

void send(ClusterNode address,
        ClusterMessageReceiver receiver,
        ClusterMessage message,
        RequestOptions options,
        ClusterMessageSender.Callback callback)
          throws java.lang.Exception

异步发送

抛出:

java.lang.Exception

cast

void cast(ClusterMessageReceiver receiver,
        ClusterMessage message,
        RequestOptions options,
        ClusterMessageSender.CastCallback castCallback)
          throws java.lang.Exception

异步广播

抛出:

java.lang.Exception