aboutsummaryrefslogtreecommitdiff
path: root/juick-notifications/src/main/java/com/juick
diff options
context:
space:
mode:
authorGravatar Vitaly Takmazov2018-09-21 09:11:19 +0300
committerGravatar Vitaly Takmazov2018-09-21 09:11:19 +0300
commitfb58da1b5da4d802a9a4305c74f6c1090ba925f6 (patch)
tree4630c9cd5b732e6ba9e0807efae254d8181962ea /juick-notifications/src/main/java/com/juick
parentd9bc70ab3c317801beae801df7b7da5af622f30c (diff)
add TaskScheduler
Diffstat (limited to 'juick-notifications/src/main/java/com/juick')
-rw-r--r--juick-notifications/src/main/java/com/juick/components/configuration/JuickServerWebsocketConfiguration.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/juick-notifications/src/main/java/com/juick/components/configuration/JuickServerWebsocketConfiguration.java b/juick-notifications/src/main/java/com/juick/components/configuration/JuickServerWebsocketConfiguration.java
index bc7f59fb..c35dfc7d 100644
--- a/juick-notifications/src/main/java/com/juick/components/configuration/JuickServerWebsocketConfiguration.java
+++ b/juick-notifications/src/main/java/com/juick/components/configuration/JuickServerWebsocketConfiguration.java
@@ -14,7 +14,9 @@ import org.springframework.http.ResponseEntity;
import org.springframework.http.client.ClientHttpRequestInterceptor;
import org.springframework.http.client.InterceptingClientHttpRequestFactory;
import org.springframework.http.client.support.BasicAuthorizationInterceptor;
+import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.concurrent.ConcurrentTaskScheduler;
import org.springframework.web.client.HttpClientErrorException;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.socket.client.WebSocketConnectionManager;
@@ -67,4 +69,8 @@ public class JuickServerWebsocketConfiguration {
public StandardWebSocketClient client() {
return new StandardWebSocketClient();
}
+ @Bean
+ public TaskScheduler taskScheduler() {
+ return new ConcurrentTaskScheduler();
+ }
}