Overview

repositories {     jcenter()    maven { url"https://jitpack.io" }}dependencies {    implementation'com.github.NaikSoftware:StompProtocolAndroid:{latest version}'}

Example backend (Spring Boot)

@Configuration@EnableWebSocket@EnableWebSocketMessageBrokerclassWebSocketConfigextendsAbstractWebSocketMessageBrokerConfigurer {@OverridevoidconfigureMessageBroker(MessageBrokerRegistryconfig) {        config.enableSimpleBroker("/topic","/queue","/exchange");//        config.enableStompBrokerRelay("/topic", "/queue", "/exchange"); // Uncomment for external message broker (ActiveMQ, RabbitMQ)        config.setApplicationDestinationPrefixes("/topic","/queue");// prefix in client queries        config.setUserDestinationPrefix("/user");    }@OverridevoidregisterStompEndpoints(StompEndpointRegistryregistry) {        registry.addEndpoint("/example-endpoint").withSockJS()    }}

@Slf4j@RestControllerclassSocketController {@MessageMapping('/hello-msg-mapping')@SendTo('/topic/greetings')EchoModelechoMessageMapping(Stringmessage) {        log.debug("React to hello-msg-mapping")returnnewEchoModel(message.trim())    }}

Example library usage

privateStompClientmStompClient;// ...mStompClient =Stomp.over(Stomp.ConnectionProvider.OKHTTP,"ws://10.0.2.2:8080/example-endpoint/websocket");mStompClient.connect();mStompClient.topic("/topic/greetings").subscribe(topicMessage -> {Log.d(TAG,topicMessage.getPayload()); });mStompClient.send("/topic/hello-msg-mapping","My first STOMP message!").subscribe();// ...mStompClient.disconnect();

mStompClient.lifecycle().subscribe(lifecycleEvent -> {switch (lifecycleEvent.getType()) {caseOPENED:Log.d(TAG,"Stomp connection opened");break;caseERROR:Log.e(TAG,"Error",lifecycleEvent.getException());break;caseCLOSED:Log.d(TAG,"Stomp connection closed");break;    }});