Skip to content

Commit

Permalink
body encode empty byte bug fix
Browse files Browse the repository at this point in the history
  • Loading branch information
ohun committed Jan 8, 2016
1 parent 88f3aad commit b125ab1
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -42,9 +42,9 @@ public void handle(final GatewayPushMessage message) {
//2.如果是本地路由信息,说明用户链接在当前机器,直接把消息下发到客户端
Connection connection = (Connection) router.getRouteValue();
if (!connection.isConnected()) {
LOGGER.info("gateway push, router in local but disconnect, userId={}, connection={}", message.userId, connection);
RouterCenter.INSTANCE.getLocalRouterManager().unRegister(message.userId);
handle(message);//递归在试一次,看用户是否登陆在远程
LOGGER.info("gateway push, router in local but disconnect userId={}, connection={}", message.userId, connection);
return;
}
PushMessage pushMessage = new PushMessage(message.content, connection);
Expand Down

0 comments on commit b125ab1

Please sign in to comment.