com.fr.cluster.engine.transport.context.impl

类 FineClusterMessageSender

java.lang.Object

com.fr.cluster.engine.transport.context.impl.FineClusterMessageSender

所有已实现的接口:

ClusterMessageSender

public class FineClusterMessageSender
extends java.lang.Object
implements ClusterMessageSender

Created by juhaoyu on 2017/12/20. ClusterMessage发送器实现

嵌套类概要

从接口继承的嵌套类/接口 com.fr.cluster.engine.transport.context.ClusterMessageSender

ClusterMessageSender.Callback, ClusterMessageSender.CastCallback

构造器概要

构造器

构造器和说明
FineClusterMessageSender(Channel jChannel, MessageDispatcher jDispatcher, MessageWrapper<?> wrapper)

方法概要

方法

限定符和类型	方法和说明
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) 异步发送

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FineClusterMessageSender

public FineClusterMessageSender(Channel jChannel,
                        MessageDispatcher jDispatcher,
                        MessageWrapper<?> wrapper)

方法详细资料

send

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

从接口复制的说明: ClusterMessageSender

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

指定者:

send 在接口中 ClusterMessageSender

抛出:

java.lang.Exception

cast

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

从接口复制的说明: ClusterMessageSender

对特定接受者广播消息

指定者:

cast 在接口中 ClusterMessageSender

抛出:

java.lang.Exception

send

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

从接口复制的说明: ClusterMessageSender

异步发送

指定者:

send 在接口中 ClusterMessageSender

抛出:

java.lang.Exception

cast

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

从接口复制的说明: ClusterMessageSender

异步广播

指定者:

cast 在接口中 ClusterMessageSender

抛出:

java.lang.Exception