Skip to content

Commit e15ee50

Browse files
committed
use ssl option implemented
1 parent 96d019c commit e15ee50

File tree

2 files changed

+15
-1
lines changed

2 files changed

+15
-1
lines changed

src/main/java/com/semihunaldi/springwebsocketwrapper/WebSocketSettings.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ public class WebSocketSettings {
1010

1111
private String host;
1212
private Integer port;
13+
private boolean useSSL;
1314

1415
private String socketName;
1516

@@ -63,6 +64,14 @@ public void setPort(Integer port) {
6364
this.port = port;
6465
}
6566

67+
public boolean isUseSSL() {
68+
return useSSL;
69+
}
70+
71+
public void setUseSSL(boolean useSSL) {
72+
this.useSSL = useSSL;
73+
}
74+
6675
public String getSocketName() {
6776
return socketName;
6877
}

src/main/java/com/semihunaldi/springwebsocketwrapper/WebSocketWrapper.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,12 @@ private ListenableFuture<StompSession> connect(WebSocketSettings webSocketSettin
4949
SockJsClient sockJsClient = new SockJsClient(transports);
5050
sockJsClient.setMessageCodec(new Jackson2SockJsMessageCodec());
5151
WebSocketStompClient stompClient = new WebSocketStompClient(sockJsClient);
52-
String url = "ws://{host}:{port}" + (webSocketSettings.getSocketName().startsWith("/") ? webSocketSettings.getSocketName() : "/" + webSocketSettings.getSocketName());
52+
String url = "//{host}:{port}" + (webSocketSettings.getSocketName().startsWith("/") ? webSocketSettings.getSocketName() : "/" + webSocketSettings.getSocketName());
53+
if(webSocketSettings.isUseSSL()) {
54+
url = "wss:" + url;
55+
} else {
56+
url = "ws:" + url;
57+
}
5358
return stompClient.connect(url, headers, new MyHandler(), webSocketSettings.getHost(), webSocketSettings.getPort());
5459
}
5560

0 commit comments

Comments
 (0)