Redis Publish/Subscribe

// room.ftl
createRoom: function() {
	var params = new URLSearchParams();
	axios.post('/chat/room', params)

// ChatController.java
@PostMapping("/room")
@ResponseBody
public ChatRoom createRoom(@RequestParam String name) {
    return chatService.createRoom(name);
}

axios.get('/chat/user').then(response => {
    _this.token = response.data.token;
    ws.connect({"token":_this.token}, function(frame) {
				// 채팅방에 들어오는 메시지를 계속 수신
		    ws.subscribe("/subscribe/chat/room/" + _this.roomId, function(message) {
		    var recv = JSON.parse(message.body);
        _this.recvMessage(recv);
        });
				// 유저가 입장한 내용을 입장한 채팅방에 발신
        _this.**sendMessage**('ENTER');
    }

// 생성한 토큰값 전달하여 유저 정보를 확인
sendMessage: function(type) {
    ws.send("/publish/chat/message", {"token":this.token}, JSON.stringify({messageType:type, roomId:this.roomId, sender:this.sender, message:this.message}));
    this.message = '';
},

// publisher
    @MessageMapping("/chat/message")
    public void sendMessage(ChatMessage chatMessage, @Header("token") String token) {
        String nickname = jwtTokenProvider.getUserNameFromJwt(token);
        chatMessage.setSender(nickname);
        if (chatMessage.getMessageType().equals(MessageType.ENTER)) {
            chatMessage.setMessage(nickname + " 님이 입장하셨습니다.");
        }
        **redisTemplate.convertAndSend(channelTopic.getTopic(), chatMessage);**
    }

class RedisConfig {
// ...
		@Bean
    public MessageListenerAdapter listenerAdapter(RedisSubscriber subscriber) {
        return new MessageListenerAdapter(subscriber, "sendMessage");
    }
//...
}

public class RedisSubscriber {
// ...
	public void sendMessage(String publishMessage) {
    try {
      ChatMessage chatMessage = objectMapper.readValue(publishMessage, ChatMessage.class);
	    messageSendingOperations.convertAndSend("/subscribe/chat/room/" + chatMessage.getRoomId(), chatMessage);
    } catch (Exception e) {
	  log.error("Exception {}", e);
	}
}

created() {
            this.roomId = localStorage.getItem('wschat.roomId');
            this.sender = localStorage.getItem('wschat.sender');
            this.findRoom();
            var _this = this;
            axios.get('/chat/user').then(response => {
                _this.token = response.data.token;
                ws.connect({"token":_this.token}, function(frame) {
                    ws.subscribe(" /subscribe/chat/room/" + _this.roomId, function(message) {
                        var recv = JSON.parse(message.body);
                        _this.recvMessage(recv);
                    });
                    _this.sendMessage('ENTER');
                }, function (error) {
                    alert("서버 연결에 실패했습니다. 다시 접속해 주세요.");
                    location.href="/chat/room";
                });
            });
        },