ストンプクライアントはSessionSubscribeEventが

Question

に起こっているとき、私は

@Service 
public class UserSubscribeEventListenerService { 

    private SimpMessagingTemplate template; 
    @Autowired 
    private GenericService<User> userService; 

    @Autowired 
    public UserSubscribeEventListenerService(SimpMessagingTemplate template) { 
     this.template = template; 
    } 

    @EventListener 
    public void handleSubscribeEvent(SessionSubscribeEvent event) { 
     try { 
      String subscribedUser = event.getUser().getName(); 
      System.out.println("User is " + event.getUser().getName() + " Message is " + "GREETINGS"); 
      Thread.sleep(3000); 
      System.out.println("AFTER 3 seconds...."); 
      template.convertAndSendToUser(subscribedUser, "/user/"+subscribedUser+ "/notify", userService.getByEmail(subscribedUser)); 
     } catch (MessagingException e) { 
      System.out.println(e.getCause() 
        + "\n\n" 
        + e.getCause()); 
      return; 
     } catch (InterruptedException e) { 
      System.out.println(e.getCause() 
        + "\n\n" 
        + e.getCause()); 
      return; 
     } 
    }  
} 

としてリスナーをサブスクライブしたメッセージ/通知を取得していないが、ストンプのためのJS関数の集まりですが、

<script type="text/javascript">  
    //Create stomp client over sockJS protocol 
    var socket = new SockJS("/ws"); 
    ///var socket = new SockJS("/ws"); 
    var stompClient = Stomp.over(socket); 
    $(document).ready(function() { 
     stompClient.connect({}, function(s) {  

       stompClient.subscribe('/user/' + s.headers['user-name'] + '/notify', function(frame){ 
        var messages = JSON.parse(frame.body) 

         var i; 
         var count = 0; 
         for(i in messages) { 
          var message = messages[i]; 
          count ++; 
          if(count <= 5){ 
           $('#user_message_addon').append(
           $('<li>').append(          
             $('<span></span>').html(message.notificationMessage) 
            ), 
            $('</li>')  
           ) 
          ); 
          } 
         }        
       });    

      }); 
     }); 
    </script> 

の下に与えられたクライアント側がありますUserSubscribeEventListenerServiceイベントが発生したときにクライアント側でコンソール出力が表示されている

メッセージや通知を受け取ることができません。

問題の解決方法を教えてください。私は春の変更は、ユーザー名に応じた名前自体をキュー考える

template.convertAndSendToUser(subscribedUser, "/notify", userService.getByEmail(subscribedUser)); 

または

template.convertAndSendToUser(subscribedUser, "/user/notify", userService.getByEmail(subscribedUser)); 

：

Answer 1

あなたはにconvertAndSendToUserの引数を変更してみてくださいました。 それとも、convertAndSend方法でそれを行うことができます：（？あなたは、あなたの質問にそれを含めることができます）それはあなたのWebSocketの構成によって異なり

template.convertAndSend("/"+subscribedUser+"/notify", userService.getByEmail(subscribedUser)); 

または

template.convertAndSend("/user/"+subscribedUser+"/notify", userService.getByEmail(subscribedUser));