diff options
author | 2017-11-01 13:53:50 +0300 | |
---|---|---|
committer | 2017-11-01 14:11:08 +0300 | |
commit | a224f31fe050fe1eeb4435677caa27d523897704 (patch) | |
tree | d4e81d11a326a8a6db58a5c4daca88ec49f6f230 /juick-api/src/main/java/com/juick/api/TelegramBotManager.java | |
parent | e2c2cf416db9637ebd41c489cf5a533824d17d4c (diff) |
api: try reconnect ws component
Diffstat (limited to 'juick-api/src/main/java/com/juick/api/TelegramBotManager.java')
-rw-r--r-- | juick-api/src/main/java/com/juick/api/TelegramBotManager.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/juick-api/src/main/java/com/juick/api/TelegramBotManager.java b/juick-api/src/main/java/com/juick/api/TelegramBotManager.java index b9154424..44f0fdc6 100644 --- a/juick-api/src/main/java/com/juick/api/TelegramBotManager.java +++ b/juick-api/src/main/java/com/juick/api/TelegramBotManager.java @@ -18,6 +18,7 @@ package com.juick.api; import com.fasterxml.jackson.databind.ObjectMapper; +import com.juick.server.component.DisconnectedEvent; import com.juick.service.MessagesService; import com.juick.service.SubscriptionService; import com.juick.service.TelegramService; @@ -33,6 +34,7 @@ import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.ApplicationEventPublisher; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.web.socket.CloseStatus; @@ -68,6 +70,8 @@ public class TelegramBotManager extends TextWebSocketHandler { private SubscriptionService subscriptionService; @Inject private ObjectMapper jsonMapper; + @Inject + private ApplicationEventPublisher applicationEventPublisher; private WebSocketSession session; @@ -99,6 +103,7 @@ public class TelegramBotManager extends TextWebSocketHandler { @Override public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception { logger.info("WebSocket disconnected with code {}: {}", status.getCode(), status.getReason()); + applicationEventPublisher.publishEvent(new DisconnectedEvent(this)); } @Scheduled(fixedRate = 30000) |