diff options
author | Vitaly Takmazov | 2017-01-13 17:03:26 +0300 |
---|---|---|
committer | Vitaly Takmazov | 2017-01-13 17:03:26 +0300 |
commit | acef82fecd92aec828a05fabc1fb29da7a645d33 (patch) | |
tree | 691caa72b6d999422cceb5972992a2a695670ba9 /juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java | |
parent | 98658ebab12286a56a7a018ba6a92026533dde7c (diff) |
juick-crosspost: xmpp -> ws
Diffstat (limited to 'juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java')
-rw-r--r-- | juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java b/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java index 95449589..2fcd3bfe 100644 --- a/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java +++ b/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java @@ -6,6 +6,8 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.core.env.Environment; +import org.springframework.web.socket.client.WebSocketConnectionManager; +import org.springframework.web.socket.client.standard.StandardWebSocketClient; import javax.inject.Inject; @@ -24,4 +26,17 @@ public class CrosspostAppConfiguration { public Crosspost crosspost() { return new Crosspost(env, crosspostService); } + private static final String WS_URI = "wss://ws.juick.com/"; + + @Bean + public WebSocketConnectionManager connectionManager() { + WebSocketConnectionManager manager = new WebSocketConnectionManager(client(), crosspost(), WS_URI); + manager.setAutoStartup(true); + return manager; + } + + @Bean + public StandardWebSocketClient client() { + return new StandardWebSocketClient(); + } } |