fix(ball-common): 修复当事件处理失败时直接会阻塞后续redis消息的bug
This commit is contained in:
@@ -25,7 +25,11 @@ public class BallRedisListener implements RedisPubSubListener<String, BallMessag
|
|||||||
if (ballMessage.getReceiverID() != null && !ballAPI.isLocalServer(ballMessage.getReceiverID())) {
|
if (ballMessage.getReceiverID() != null && !ballAPI.isLocalServer(ballMessage.getReceiverID())) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
eventBus.post(new MessageReceivedEvent(channel, ballMessage));
|
try {
|
||||||
|
eventBus.post(new MessageReceivedEvent(channel, ballMessage));
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@@ -44,13 +44,8 @@ subprojects {
|
|||||||
duplicatesStrategy = DuplicatesStrategy.EXCLUDE
|
duplicatesStrategy = DuplicatesStrategy.EXCLUDE
|
||||||
}
|
}
|
||||||
jar {
|
jar {
|
||||||
archiveClassifier = "dev"
|
archiveClassifier = "FIX"
|
||||||
}
|
destinationDirectory = rootProject.layout.buildDirectory
|
||||||
shadowJar {
|
|
||||||
archiveClassifier = ""
|
|
||||||
}
|
|
||||||
build {
|
|
||||||
dependsOn(shadowJar)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user