Commit 5ec135e1 authored by AfirSraftGarrier's avatar AfirSraftGarrier

格式并加些打印

parent c1ee6f31
...@@ -11,7 +11,6 @@ import org.springframework.stereotype.Component; ...@@ -11,7 +11,6 @@ import org.springframework.stereotype.Component;
@Component @Component
@Slf4j @Slf4j
public class ForwardClientInactiveEventHandler { public class ForwardClientInactiveEventHandler {
@Autowired @Autowired
DeviceManager deviceManager; DeviceManager deviceManager;
@Autowired @Autowired
...@@ -20,7 +19,6 @@ public class ForwardClientInactiveEventHandler { ...@@ -20,7 +19,6 @@ public class ForwardClientInactiveEventHandler {
EventPublisher eventPublisher; EventPublisher eventPublisher;
public ForwardClientInactiveEventHandler() { public ForwardClientInactiveEventHandler() {
} }
@EventListener @EventListener
...@@ -35,14 +33,12 @@ public class ForwardClientInactiveEventHandler { ...@@ -35,14 +33,12 @@ public class ForwardClientInactiveEventHandler {
String appId = session.getAppId(); String appId = session.getAppId();
boolean result = forwardManager.removeSessionByChannelId(channelId); boolean result = forwardManager.removeSessionByChannelId(channelId);
if (result) { if (result) {
// TODO forward client 离线需要强制中断该设备对应的 device client // forward client 离线需要强制中断该设备对应的 device client
DeviceClientBeForcedOfflineEvent deviceClientBeForcedOfflineEvent = new DeviceClientBeForcedOfflineEvent(); DeviceClientBeForcedOfflineEvent deviceClientBeForcedOfflineEvent = new DeviceClientBeForcedOfflineEvent();
deviceClientBeForcedOfflineEvent.setAppId(appId); deviceClientBeForcedOfflineEvent.setAppId(appId);
eventPublisher.publishEvent(deviceClientBeForcedOfflineEvent); eventPublisher.publishEvent(deviceClientBeForcedOfflineEvent);
log.debug("forward client inactive success ..."); log.debug("forward client inactive success ...");
} }
} }
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment