Skip to content

Commit 872dc4f

Browse files
committed
Solution for issue NaikSoftware#19
1 parent 7fc11fa commit 872dc4f

File tree

3 files changed

+4
-9
lines changed

3 files changed

+4
-9
lines changed

.idea/markdown-navigator/profiles_settings.xml

-3
This file was deleted.

.idea/vcs.xml

-6
This file was deleted.

lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java

+4
Original file line numberDiff line numberDiff line change
@@ -122,6 +122,10 @@ public Observable<Void> send(StompMessage stompMessage) {
122122
mWaitConnectionObservables.add(deffered);
123123
return deffered;
124124
} else {
125+
if(stompMessage.getStompCommand().equals(StompCommand.SUBSCRIBE)){
126+
ConnectableObservable<Void> send = mConnectionProvider.send(stompMessage.compile()).publish();
127+
send.connect();
128+
}
125129
return observable;
126130
}
127131
}

0 commit comments

Comments
 (0)