Contents

# frozen_string_literal: true

require 'delegate'

require 'active_support/core_ext/numeric/time'
require 'net/http/persistent'

require 'artemis/adapters/net_http_adapter'

module Artemis
  module Adapters
    class NetHttpPersistentAdapter < NetHttpAdapter
      attr_reader :_connection, :raw_connection

      def initialize(uri, service_name: , timeout: , pool_size: )
        super

        @raw_connection = Net::HTTP::Persistent.new(name: service_name, pool_size: pool_size)
        @raw_connection.open_timeout = timeout
        @raw_connection.read_timeout = timeout
        @raw_connection.idle_timeout = 30.minutes.to_i # TODO: Make it configurable

        @_connection = ConnectionWrapper.new(@raw_connection, uri)
      end

      # Public: Extension point for subclasses to customize the Net:HTTP client
      #
      # Returns a Net::HTTP object
      def connection
        _connection
      end

      class ConnectionWrapper < SimpleDelegator #:nodoc:
        def initialize(obj, url)
          super(obj)

          @url = url
        end

        def request(req)
          __getobj__.request(@url, req)
        end
      end

      private_constant :ConnectionWrapper
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
artemis-0.5.2	lib/artemis/adapters/net_http_persistent_adapter.rb
artemis-0.5.1	lib/artemis/adapters/net_http_persistent_adapter.rb
artemis-0.5.0	lib/artemis/adapters/net_http_persistent_adapter.rb
artemis-0.4.0	lib/artemis/adapters/net_http_persistent_adapter.rb
artemis-0.2.0	lib/artemis/adapters/net_http_persistent_adapter.rb