refactor: change log level from warning to fine for deserialization errors in event and request buses

Author: twisti-dev

src/main/kotlin/dev/slne/surf/redis/event/RedisEventBus.kt

@@ -109,7 +109,7 @@ class RedisEventBus internal constructor(private val api: RedisApi) {
         val envelope = try {
             api.json.decodeFromString<EventEnvelope>(message)
         } catch (e: SerializationException) {
-            log.atWarning()
+            log.atFine()
                 .withCause(e)
                 .log("Unable to deserialize event envelope: ${e.message}")
             return
@@ -118,9 +118,7 @@ class RedisEventBus internal constructor(private val api: RedisApi) {
         val eventClass = eventTypeRegistry[envelope.eventClass]
 
         if (eventClass == null) {
-            log.atSevere()
-                .per(envelope.eventClass, LogPerBucketingStrategy.byHashCode(128))
-                .atMostEvery(1, TimeUnit.MINUTES)
+            log.atFine()
                 .log("No registered event class for name: ${envelope.eventClass} - ignoring event.")
             return
         }

src/main/kotlin/dev/slne/surf/redis/request/RequestResponseBus.kt

@@ -108,7 +108,7 @@ class RequestResponseBus internal constructor(
         val envelope = try {
             api.json.decodeFromString<RequestEnvelope>(message)
         } catch (e: SerializationException) {
-            log.atWarning()
+            log.atFine()
                 .withCause(e)
                 .log("Unable to deserialize request envelope: ${e.message}")
             return
@@ -117,9 +117,7 @@ class RequestResponseBus internal constructor(
         val requestClass = requestTypeRegistry[envelope.requestClass]
 
         if (requestClass == null) {
-            log.atSevere()
-                .per(envelope.requestClass, LogPerBucketingStrategy.byHashCode(128))
-                .atMostEvery(1, TimeUnit.MINUTES)
+            log.atFine()
                 .log("No registered request class for name: ${envelope.requestClass} - ignoring request.")
             return
         }
@@ -153,7 +151,7 @@ class RequestResponseBus internal constructor(
         val envelope = try {
             api.json.decodeFromString<ResponseEnvelope>(message)
         } catch (e: SerializationException) {
-            log.atWarning()
+            log.atFine()
                 .withCause(e)
                 .log("Unable to deserialize response envelope: ${e.message}")
             return
@@ -162,9 +160,7 @@ class RequestResponseBus internal constructor(
         val responseClass = responseTypeRegistry[envelope.responseClass]
 
         if (responseClass == null) {
-            log.atWarning()
-                .per(envelope.responseClass, LogPerBucketingStrategy.byHashCode(128))
-                .atMostEvery(1, TimeUnit.MINUTES)
+            log.atFine()
                 .log("No registered response class for name: ${envelope.responseClass} - ignoring response.")
             return
         }