Merge pull request #250 from memphisdev/memphis-nats-integrartion-http

Integrate HTTP server
superstreamlabs · Aug 9, 2022 · 2ad75d9 · 2ad75d9
2 parents f30d75b + 7060d25
commit 2ad75d9
Show file tree

Hide file tree

Showing 179 changed files with 899 additions and 790 deletions.
diff --git a/background_tasks/poison_messages_listener.go b/background_tasks/poison_messages_listener.go
@@ -14,12 +14,14 @@
 package background_tasks
 
 import (
-	"memphis-broker/broker"
 	"memphis-broker/handlers"
+	"memphis-broker/server"
 )
 
-var poisonMessagesHandler = handlers.PoisonMessagesHandler{}
+var poisonMessagesHandler handlers.PoisonMessagesHandler
 
-func ListenForPoisonMessages() {
-	broker.QueueSubscribe("$JS.EVENT.ADVISORY.CONSUMER.MAX_DELIVERIES.>", "$memphis_poison_messages_listeners_group", poisonMessagesHandler.HandleNewMessage)
+func ListenForPoisonMessages(s *server.Server) {
+	s.QueueSubscribe("$JS.EVENT.ADVISORY.CONSUMER.MAX_DELIVERIES.>",
+		"$memphis_poison_messages_listeners_group",
+		poisonMessagesHandler.HandleNewMessage)
 }