update errors for encode/decode exceptions

ideacrew · Dec 30, 2024 · 1b80d76 · 1b80d76
1 parent d24195a
commit 1b80d76
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/lib/event_source/error.rb b/lib/event_source/error.rb
@@ -32,7 +32,7 @@ class Error < StandardError
     ServerConfigurationNotFound = Class.new(Error)
     ServerConfigurationInvalid = Class.new(Error)
     MessageBuildError = Class.new(Error)
-    PayloadCompressionError = Class.new(Error)
-    PayloadDecompressionError = Class.new(Error)
+    PayloadEncodeError = Class.new(Error)
+    PayloadDecodeError = Class.new(Error)
   end
 end
diff --git a/lib/event_source/protocols/amqp/bunny_queue_proxy.rb b/lib/event_source/protocols/amqp/bunny_queue_proxy.rb
@@ -163,7 +163,7 @@ def decode_payload(payload)
             output.value!
           else
             logger.error "Failed to decompress message \n  due to: #{output.failure}"
-            raise EventSource::Error::PayloadDecompressionError, output.failure
+            raise EventSource::Error::PayloadDecodeError, output.failure
           end
         end
 

diff --git a/lib/event_source/publish_operation.rb b/lib/event_source/publish_operation.rb
@@ -48,7 +48,7 @@ def encode_payload(payload)
         output.value!
       else
         logger.error "Failed to decompress message \n  due to: #{output.failure}"
-        raise EventSource::Error::PayloadCompressionError, output.failure
+        raise EventSource::Error::PayloadEncodeError, output.failure
       end
     end
   end