feat: 优化结构
This commit is contained in:
@@ -419,10 +419,10 @@ public abstract class BallAPI {
|
||||
*/
|
||||
public void sendBallMessage(@NotNull String channel, @NotNull BallMessage message, boolean block) {
|
||||
if (block) {
|
||||
pubConnection.sync().publish(BALL_CHANNEL, message);
|
||||
pubConnection.sync().publish(channel, message);
|
||||
eventBus.post(new MessageSentEvent(channel, message));
|
||||
} else {
|
||||
pubConnection.async().publish(BALL_CHANNEL, message).whenComplete((aLong, throwable) -> {
|
||||
pubConnection.async().publish(channel, message).whenComplete((aLong, throwable) -> {
|
||||
if (throwable != null) {
|
||||
return;
|
||||
}
|
||||
|
Reference in New Issue
Block a user