From 343cefcfec3744d0f891ab43de678f08135bb685 Mon Sep 17 00:00:00 2001
From: its-a-feature <codybthomas@gmail.com>
Date: Mon, 10 Feb 2025 09:08:39 -0600
Subject: [PATCH] rabbitmq queue tweaks

---
 CHANGELOG.MD                                         | 6 ++++++
 VERSION                                              | 2 +-
 mythic-docker/src/VERSION                            | 2 +-
 mythic-docker/src/rabbitmq/utils_rabbitmq_routing.go | 5 ++---
 4 files changed, 10 insertions(+), 5 deletions(-)

diff --git a/CHANGELOG.MD b/CHANGELOG.MD
index d6f3530e..de555309 100644
--- 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
index eeb6ee9f..67a04028 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-3.3.1-rc40
\ No newline at end of file
+3.3.1-rc41
\ No newline at end of file
diff --git a/mythic-docker/src/VERSION b/mythic-docker/src/VERSION
index 6ab6335c..67a04028 100644
--- a/mythic-docker/src/VERSION
+++ b/mythic-docker/src/VERSION
@@ -1 +1 @@
-3.3.1-rc340
\ No newline at end of file
+3.3.1-rc41
\ No newline at end of file
diff --git a/mythic-docker/src/rabbitmq/utils_rabbitmq_routing.go b/mythic-docker/src/rabbitmq/utils_rabbitmq_routing.go
index ef1d3dd3..4b2c1255 100644
--- 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,