From d24195a38eb4e454e570f68f2ad73d4d1c513077 Mon Sep 17 00:00:00 2001 From: Raghu Ram Date: Mon, 30 Dec 2024 16:25:38 -0500 Subject: [PATCH] update method names --- lib/event_source/protocols/amqp/bunny_queue_proxy.rb | 4 ++-- lib/event_source/publish_operation.rb | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/event_source/protocols/amqp/bunny_queue_proxy.rb b/lib/event_source/protocols/amqp/bunny_queue_proxy.rb index eb04de9..c449ad8 100644 --- 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 index 7eb6735..432fa8c 100644 --- a/lib/event_source/publish_operation.rb +++ b/lib/event_source/publish_operation.rb @@ -28,7 +28,7 @@ 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], @@ -36,7 +36,7 @@ def call(payload, options = {}) ) 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']