update method names

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

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/lib/event_source/protocols/amqp/bunny_queue_proxy.rb b/lib/event_source/protocols/amqp/bunny_queue_proxy.rb
@@ -135,7 +135,7 @@ def on_receive_message(
 
           subscriber = subscriber_klass.new
           subscriber.channel = @subject.channel
-          payload = decompress_payload_if_binary(payload)
+          payload = decode_payload(payload)
           subscription_handler =
             EventSource::Protocols::Amqp::BunnyConsumerHandler.new(
               subscriber,
@@ -151,7 +151,7 @@ def on_receive_message(
           subscriber = nil
         end
 
-        def decompress_payload_if_binary(payload)
+        def decode_payload(payload)
           async_api_subscribe_operation = @async_api_channel_item.subscribe
           return payload unless async_api_subscribe_operation.message
 

diff --git a/lib/event_source/publish_operation.rb b/lib/event_source/publish_operation.rb
@@ -28,15 +28,15 @@ def initialize(channel, publish_proxy, async_api_publish_operation)
     # @example
     #   #publish("Message", :headers => { })
     def call(payload, options = {})
-      payload = compress_payload_if_required(payload)
+      payload = encode_payload(payload)
       @subject.publish(
         payload: payload,
         publish_bindings: @async_api_publish_operation[:bindings],
         headers: options[:headers] || {}
       )
     end
 
-    def compress_payload_if_required(payload)
+    def encode_payload(payload)
       return payload unless @async_api_publish_operation.message
 
       message_bindings = @async_api_publish_operation.message['bindings']