@Spi(order = 1)
public final class GatewayPushListener implements PushListener<GatewayPushMessage>, PushListenerFactory<GatewayPushMessage> {
@Override
public void onSuccess(GatewayPushMessage message) {
if (message.getConnection().isConnected()) {
<BUG>OkMessage
.from(message)</BUG>
.setData(message.userId + ',' + message.clientType)
<BUG>.sendRaw();
} else {</BUG>
Logs.PUSH.warn("push message to client success, but gateway connection is closed, message={}", message);

@Spi(order = 1)
public final class GatewayPushListener implements PushListener<GatewayPushMessage>, PushListenerFactory<GatewayPushMessage> {
@Override
public void onSuccess(GatewayPushMessage message) {
if (message.getConnection().isConnected()) {
message.runInRequestThread(() -> OkMessage
.from(message)
.setData(message.userId + ',' + message.clientType)
.sendRaw()
);
} else {
Logs.PUSH.warn("push message to client success, but gateway connection is closed, message={}", message);
