Contents

# frozen_string_literal: true

module SalesforceStreamer
  class MessageReceiver
    class << self
      # @param topic [String] The unique Salesforce Topic name
      # @param handler [Object] An object that responds to .call(message)
      # @param message [Hash] The event payload
      def call(topic, handler, message)
        if handler.respond_to? :perform_async
          handler.perform_async message
        else
          handler.call message
        end
        ReplayPersistence.record topic, message.dig('event', 'replayId')
      rescue StandardError => e
        Configuration.instance.exception_adapter.call e
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
salesforce_streamer-0.3.0	lib/salesforce_streamer/message_receiver.rb
salesforce_streamer-0.2.3	lib/salesforce_streamer/message_receiver.rb
salesforce_streamer-0.2.2	lib/salesforce_streamer/message_receiver.rb
salesforce_streamer-0.2.1	lib/salesforce_streamer/message_receiver.rb
salesforce_streamer-0.2.0	lib/salesforce_streamer/message_receiver.rb