third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: optimize akka remote impl

Browse Source
This commit is contained in:
tjq 2023-01-02 11:21:49 +08:00
parent af8fbb0167
commit f2b9ae222a
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java
View File

@ -66,7 +66,7 @@ public class AkkaCSInitializer implements CSInitializer {
@Override @Override
public void bindHandlers(List<ActorInfo> actorInfos) { public void bindHandlers(List<ActorInfo> actorInfos) {
// TODO: 考虑如何优雅绑定（实在不行就暴力绑定到一个 actor 上，反正可以切协议）
} }
@Override @Override

3
powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaTransporter.java
View File

@ -40,6 +40,9 @@ public class AkkaTransporter implements Transporter {
private static final Map<String, String> SERVER_PATH_MAP = Maps.newHashMap(); private static final Map<String, String> SERVER_PATH_MAP = Maps.newHashMap();
private static final Map<String, String> WORKER_PATH_MAP = Maps.newHashMap(); private static final Map<String, String> WORKER_PATH_MAP = Maps.newHashMap();
/*
HandlerLocation#fullPath -> actorName
*/
static { static {
SERVER_PATH_MAP.put("", ""); SERVER_PATH_MAP.put("", "");