messageProcesserの並列処理実装がミスっていたのを修正

traP-jp · Dec 15, 2023 · 3294c3a · 3294c3a
1 parent 5538fad
commit 3294c3a
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/server/traqmessage/collect.go b/server/traqmessage/collect.go
@@ -72,9 +72,11 @@ type messageProcesser struct {
 
 // go routineの中で呼ぶ
 func (m *messageProcesser) run() {
-	select {
-	case messages := <-m.queue:
-		m.process(*messages)
+	for {
+		select {
+		case messages := <-m.queue:
+			m.process(*messages)
+		}
 	}
 }