|
@@ -121,7 +121,7 @@ public class DefaultDeviceSessionManager implements DeviceSessionManager {
|
|
return session
|
|
return session
|
|
.getOperator()
|
|
.getOperator()
|
|
.online(serverId, session.getId())
|
|
.online(serverId, session.getId())
|
|
- .then(Mono.fromRunnable(()-> registerListener.next(session)));
|
|
|
|
|
|
+ .then(Mono.fromRunnable(() -> registerListener.next(session)));
|
|
})
|
|
})
|
|
.flatMap(ignore -> session.getOperator().online(serverId, session.getId()))
|
|
.flatMap(ignore -> session.getOperator().online(serverId, session.getId()))
|
|
.thenReturn(false);
|
|
.thenReturn(false);
|
|
@@ -283,7 +283,7 @@ public class DefaultDeviceSessionManager implements DeviceSessionManager {
|
|
|
|
|
|
//注册中心上线
|
|
//注册中心上线
|
|
session.getOperator()
|
|
session.getOperator()
|
|
- .online(session.getServerId().orElse(serverId), session.getId())
|
|
|
|
|
|
+ .online(session.getServerId().orElse(serverId), session.getId(), session.getClientAddress().map(String::valueOf).orElse(null))
|
|
.doFinally(s -> {
|
|
.doFinally(s -> {
|
|
//通知
|
|
//通知
|
|
if (onDeviceRegister.hasDownstreams()) {
|
|
if (onDeviceRegister.hasDownstreams()) {
|