From 85335a2f43484ff715c5430520a9faba2f4c0ef7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tom=20K=C3=A4sler?= <tom.kaesler@mni.thm.de>
Date: Tue, 26 Mar 2019 15:46:29 +0100
Subject: [PATCH] fix handler to use topic for broadcasting
---
.../thm/arsnova/websocket/handler/FeedbackCommandHandler.java | 4 ++--
.../arsnova/websocket/handler/FeedbackCommandHandlerTest.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/main/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandler.java b/src/main/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandler.java
index 1921919a8..19c8de57f 100644
--- a/src/main/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandler.java
+++ b/src/main/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandler.java
@@ -39,7 +39,7 @@ public class FeedbackCommandHandler {
feedbackChanged.setPayload(feedbackChangedPayload);
messagingTemplate.convertAndSend(
- "/queue/" + command.getRoomId() + ".feedback.stream",
+ "/topic/" + command.getRoomId() + ".feedback.stream",
feedbackChanged
);
}
@@ -53,7 +53,7 @@ public class FeedbackCommandHandler {
feedbackChanged.setPayload(feedbackChangedPayload);
messagingTemplate.convertAndSend(
- "/queue/" + command.getRoomId() + ".feedback.stream",
+ "/topic/" + command.getRoomId() + ".feedback.stream",
feedbackChanged
);
}
diff --git a/src/test/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandlerTest.java b/src/test/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandlerTest.java
index 277079cc7..073c586e1 100644
--- a/src/test/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandlerTest.java
+++ b/src/test/java/de/thm/arsnova/websocket/handler/FeedbackCommandHandlerTest.java
@@ -50,7 +50,7 @@ public class FeedbackCommandHandlerTest {
ArgumentCaptor.forClass(FeedbackChanged.class);
verify(messagingTemplate).convertAndSend(topicCaptor.capture(), messageCaptor.capture());
- assertThat(topicCaptor.getValue()).isEqualTo("/queue/" + roomId + ".feedback.stream");
+ assertThat(topicCaptor.getValue()).isEqualTo("/topic/" + roomId + ".feedback.stream");
assertThat(messageCaptor.getValue()).isEqualTo(feedbackChanged);
}
@@ -68,7 +68,7 @@ public class FeedbackCommandHandlerTest {
ArgumentCaptor<String> captor = ArgumentCaptor.forClass(String.class);
verify(messagingTemplate).convertAndSend(captor.capture(), any(FeedbackChanged.class));
- assertThat(captor.getValue()).isEqualTo("/queue/" + roomId + ".feedback.stream");
+ assertThat(captor.getValue()).isEqualTo("/topic/" + roomId + ".feedback.stream");
}
}
--
GitLab