com.github.kfcfans.powerjob.worker.common.utils

类 AkkaUtils

java.lang.Object

com.github.kfcfans.powerjob.worker.common.utils.AkkaUtils

public class AkkaUtils
extends Object

AKKA 工具类

从以下版本开始:

2020/3/17

作者:

tjq

构造器概要

构造器

构造器和说明
AkkaUtils()

方法概要

限定符和类型	方法和说明
static String	getAkkaServerPath(String actorName)
static String	getAkkaWorkerPath(String address, String actorName)
static boolean	reliableTransmit(akka.actor.ActorSelection remote, Object msg) 可靠传输

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

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

构造器详细资料

AkkaUtils

public AkkaUtils()

方法详细资料

getAkkaWorkerPath

public static String getAkkaWorkerPath(String address,
                                       String actorName)

getAkkaServerPath

public static String getAkkaServerPath(String actorName)

reliableTransmit

public static boolean reliableTransmit(akka.actor.ActorSelection remote,
                                       Object msg)

可靠传输

参数:

remote - 远程 AKKA 节点

msg - 需要传输的对象

返回:

true: 对方接收成功 / false: 对方接收失败（可能传输成功但对方处理失败，需要协同处理 AskResponse 返回值）