Contents

require 'stomp'

module Katello
  module Messaging
    class StompConnection
      def initialize(settings:)
        ssl_params = Stomp::SSLParams.new(
          key_file: settings[:ssl_key_file],
          cert_file: settings[:ssl_cert_file],
          ts_files: settings[:ssl_ca_file],
          fsck: false
        )

        @config = {
          hosts: [
            {
              host: settings[:broker_host],
              port: settings[:broker_port],
              ssl: ssl_params,
            },
          ],
          logger: Rails.logger,
          max_reconnect_attempts: 2,
          start_timeout: 2,
          reliable: false,
          connect_headers: {
            'accept-version': '1.2',
            'host': settings[:broker_host],
            'heart-beat': '30000,30000',
            'client-id': settings[:client_id],
          },
        }

        @queue_name = settings[:queue_name]
        @subscription_name = settings[:subscription_name]
      end

      def subscribe(queue_name: @queue_name, subscription_name: @subscription_name)
        options = {}
        options['ack'] = 'client-individual'
        options['durable-subscription-name'] = subscription_name if subscription_name

        client.subscribe(queue_name, options) do |message|
          received_message = Katello::Messaging::ReceivedMessage.new(body: message.body, headers: message.headers)
          yield(received_message)
          client.ack(message)
        end

        Rails.logger.info("Subscribed to #{queue_name}.#{subscription_name}")
      end

      def running?
        @client&.running && @client&.open?
      end

      def open?
        @client&.open?
      end

      def close
        if open?
          @client.close
        end
      end

      private

      def client
        @client ||= ::Stomp::Client.new(@config)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
katello-4.15.0	app/lib/katello/messaging/stomp_connection.rb
katello-4.15.0.rc2	app/lib/katello/messaging/stomp_connection.rb
katello-4.15.0.rc1	app/lib/katello/messaging/stomp_connection.rb