}
}
@Override
public void onRedirect(GatewayPushMessage message) {
if (message.getConnection().isConnected()) {
<BUG>ErrorMessage
.from(message)</BUG>
.setErrorCode(ROUTER_CHANGE)
.setData(message.userId + ',' + message.clientType)
<BUG>.sendRaw();
} else {</BUG>
Logs.PUSH.warn("push message to client redirect, but gateway connection is closed, message={}", message);

}
}
@Override
public void onFailure(GatewayPushMessage message) {
if (message.getConnection().isConnected()) {
message.runInRequestThread(() ->
ErrorMessage
.from(message)
.setErrorCode(PUSH_CLIENT_FAILURE)
.setData(message.userId + ',' + message.clientType)
.sendRaw()
);
} else {
Logs.PUSH.warn("push message to client failure, but gateway connection is closed, message={}", message);
