17

I want to send notification to specific client.

e.g username user

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfiguration extends
    AbstractWebSocketMessageBrokerConfigurer {

        @Override
        public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
            stompEndpointRegistry.addEndpoint("/socket")
                    .setAllowedOrigins("*")
                    .withSockJS();
        }

        @Override
        public void configureMessageBroker(MessageBrokerRegistry registry) {
            registry.enableSimpleBroker("/topic", "/queue");
            registry.setApplicationDestinationPrefixes("/app");

        }

Controller

@GetMapping("/notify")
public String getNotification(Principal principal) {
    String username = "user";

    notifications.increment();
    logger.info("counter" + notifications.getCount() + "" + principal.getName());
    //  logger.info("usersend:"+sha.getUser().getName()) ; //user

    template.convertAndSendToUser(principal.getName(), "queue/notification", notifications);

    return "Notifications successfully sent to Angular !";
}

Client-Side

Angular Service

connect() {
    let socket = new SockJs(`api/socket`);

    let stompClient = Stomp.over(socket);

    return stompClient;
}

Angular Component

 let stompClient = this.webSocketService.connect();

     stompClient.connect({}, frame => {

      stompClient.subscribe('/user/queue/notification', notifications => {
               console.log('test'+notifications)
          this.notifications = JSON.parse(notifications.body).count;

      })     });

I am have searched many other questions and tried but none of them worked for me e.g here answered by Thanh Nguyen Van and here

Console

 Opening Web Socket...
    stomp.js:134 Web Socket Opened...
    stomp.js:134 >>> CONNECT
    accept-version:1.1,1.0
    heart-beat:10000,10000


    stomp.js:134 <<< CONNECTED
    version:1.1
    heart-beat:0,0


    stomp.js:134 connected to server undefined
    reminder.component.ts:18 test callsed
    stomp.js:134 >>> SUBSCRIBE
    id:sub-0
    destination:/user/queue/notification

thanks in advance .

naila naseem
  • 577
  • 3
  • 12
  • 21
  • I have implemented stomp and it is working, the problem is that when I close my server then I get a warning -- The web application [ROOT] appears to have started a thread named [MessageBroker-4] but has failed to stop it. This is very likely to create a memory leak. – krr Aug 06 '23 at 19:09

2 Answers2

12

The answer of gerrytan to Sending message to specific user on Spring Websocket mentions a web socket configuration change, to register the /user prefix. In your case I guess it means to replace

registry.enableSimpleBroker("/topic", "/queue");

with 

registry.enableSimpleBroker("/topic", "/queue", "/user");

He also says that in controller you don't need the /user prefix because it is added automatically. So you could try this:

template.convertAndSendToUser(principal.getName(), "/queue/notification", notifications);

and this:

template.convertAndSendToUser(principal.getName(), "/user/queue/notification", notifications);

On the client side you need to provide the username that you used to connect to server. You might insert it directly:

stompClient.subscribe('/user/naila/queue/notification', ...)

or get it from a header. But Markus says at How to send websocket message to concrete user? that even here you don't need the username, so it might work like this:

stompClient.subscribe('/user/queue/notification', ...)
edixon
  • 991
  • 6
  • 16
  • how do we handle closing the websocket connection for a particular user? – krr Aug 04 '23 at 06:14
  • What is there to handle? How a connection would be closed for a particular user? Anyway, this is unrelated to the original post, you should post this as a distinct question. – edixon Aug 04 '23 at 19:27
  • Hi edixon your answer is very helpful. I have implemented stomp and it is working, the problem is that when I close my server then I get a warning -- The web application [ROOT] appears to have started a thread named [MessageBroker-4] but has failed to stop it. This is very likely to create a memory leak. – krr Aug 05 '23 at 12:50
  • Your question has several answers here: https://stackoverflow.com/questions/48254517/. I found it at the top when googling for "the web application appears to have started". – edixon Aug 05 '23 at 18:33
  • Hello thanks for url but it discusses other issue. Were you not getting any thread or memory leak warning after terminating your app locally when you implemented your solution. – krr Aug 06 '23 at 19:07
7

Seems you are missing a slash in your destination:

template.convertAndSendToUser(principal.getName(), "/queue/notification", notifications);
Sergi Almar
  • 8,054
  • 3
  • 32
  • 30