rm prefetch

lehigh-university-libraries · Dec 15, 2024 · 15ab343 · 15ab343
1 parent 9bcc190
commit 15ab343
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/stomp.go b/stomp.go
@@ -56,7 +56,7 @@ func runStompSubscribers(config *scyllaridae.ServerConfig) {
 func RecvAndProcessMessage(queueName string, middleware scyllaridae.QueueMiddleware) error {
 	addr := os.Getenv("STOMP_SERVER_ADDR")
 	if addr == "" {
-		addr = "activemq:61613?activemq.prefetchSize=1"
+		addr = "activemq:61613"
 	}
 
 	c, err := net.Dial("tcp", addr)