Catch errors parsing broker message headers

beemobot · Dec 7, 2024 · 58b4921 · 58b4921
1 parent 88f1fa2
commit 58b4921
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/latte/src/main/java/gg/beemo/latte/broker/rabbitmq/RabbitConnection.kt b/latte/src/main/java/gg/beemo/latte/broker/rabbitmq/RabbitConnection.kt
@@ -96,9 +96,13 @@ class RabbitConnection(
                 body: ByteArray
             ) {
                 val key = envelope.routingKey ?: ""
-                val value = String(body)
-                val headers = BrokerMessageHeaders(properties.headers.mapValues { it.value.toString() })
-                dispatchIncomingMessage(topic, key, value, headers)
+                try {
+                    val value = String(body)
+                    val headers = BrokerMessageHeaders(properties.headers.mapValues { it.value.toString() })
+                    dispatchIncomingMessage(topic, key, value, headers)
+                } catch (e: Exception) {
+                    log.error("Error handling incoming broker message in topic $topic, dropping message", e)
+                }
                 channel.basicAck(envelope.deliveryTag, false)
             }