Merge pull request #125 from traP-jp/polling-properly

messageProcesserの並列処理実装がミスっていたのを修正
traP-jp · Dec 15, 2023 · 1224cd0 · 1224cd0
2 parents bc6cfe1 + 3294c3a
commit 1224cd0
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)
+		}
 	}
 }