rabbitmq queue tweaks

its-a-feature · Feb 10, 2025 · 343cefc · 343cefc
1 parent fa245e6
commit 343cefc
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 5 deletions.
diff --git a/CHANGELOG.MD b/CHANGELOG.MD
@@ -4,6 +4,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [3.3.1-rc41] - 2025-02-10
+
+### Changed
+
+- Few rabbitmq tweaks
+
 ## [3.3.1-rc40] - 2025-02-07
 
 ### Changed

diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-3.3.1-rc40
+3.3.1-rc41
diff --git a/mythic-docker/src/VERSION b/mythic-docker/src/VERSION
@@ -1 +1 @@
-3.3.1-rc340
+3.3.1-rc41
diff --git a/mythic-docker/src/rabbitmq/utils_rabbitmq_routing.go b/mythic-docker/src/rabbitmq/utils_rabbitmq_routing.go
@@ -165,7 +165,6 @@ func (r *rabbitMQConnection) GetConnection() (*amqp.Connection, error) {
 				Dial: func(network, addr string) (net.Conn, error) {
 					return net.DialTimeout(network, addr, 10*time.Second)
 				},
-				Heartbeat: 10 * time.Second, // Add heartbeat
 			},
 		)
 		if err != nil {
@@ -488,8 +487,8 @@ func (r *rabbitMQConnection) ReceiveFromRPCQueue(exchange string, queue string,
 		}
 		q, err := ch.QueueDeclare(
 			queue,          // name, queue
-			true,           // durable
-			false,          // delete when unused
+			false,          // durable
+			true,           // delete when unused
 			exclusiveQueue, // exclusive
 			false,          // no-wait
 			nil,