StompProtocolAndroid
StompProtocolAndroid copied to clipboard
STOMP protocol via WebSocket for Android
Hi Naik, I have tried to run the given sample to connect websocket from Andorid and running the backend code in spring boot like mentioned below. But I got the...
After N unsuccessful attempts to connect and one successful attempt, library replies with N+1 messages - in this case there should only be one. It works fine when no problems...
How to get session id from client when connect websocket successful?
i keep getting this error java.lang.ClassNotFoundException: Class io.reactivex.functions.Action not found anytime i add this library implementation 'com.github.NaikSoftware:StompProtocolAndroid:1.5.2' to my build.gradle file, why is this ?
I have downloaded the server example but I keep getting the same error. I have used the following server configurations: ``` @Configuration @EnableWebSocket @EnableWebSocketMessageBroker class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { @Override...
This is reproducible by subscribing to a topic and then delaying the subscription to the same topic by ~5 seconds so that the first one has time to finish connecting....
``` io.reactivex.exceptions.OnErrorNotImplementedException: The exception was not handled due to missing onError handler in the subscribe() method call. Further reading: https://github.com/ReactiveX/RxJava/wiki/Error-Handling | java.util.NoSuchElementException at io.reactivex.internal.functions.Functions$OnErrorMissingConsumer.accept(Functions.java:704) at io.reactivex.internal.functions.Functions$OnErrorMissingConsumer.accept(Functions.java:701) at io.reactivex.internal.observers.LambdaObserver.onError(LambdaObserver.java:77) at io.reactivex.internal.observers.BasicFuseableObserver.onError(BasicFuseableObserver.java:100)...
How can I disable log output when receive new message?
when i use spring boot 2.0 the webseocket server,android client cant send a message
First, I connect socket and subscribe topic. Example here: fun example() { mStompClient.topic("/topic/example") .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe{ Log.d("listenStomp", topicMessage.getPayload()); timeCount.value=it.payload } } Log console working. But I turn off internet. Socket...