ActiveMQ Consumer Ruby

active.xml

<transportConnectors>
  <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
  <transportConnector name="stomp" uri="stomp://localhost:61613"/>
</transportConnectors>

bin_console

#!/usr/bin/env ruby

require 'bundler/setup'
require 'stp'
require 'stp/consumer'

Stp::Consumer.new({
  stomp_host: ENV['STOMP_HOST'] || 'localhost',
  stomp_port: ENV['STOMP_PORT'] || 61613,
  abonos_queue: ENV['ABONOS_QUEUE'] || '/queue/abonos',
  ordenes_queue: ENV['ORDENES_QUEUE'] || '/queue/ordenes'
}).run

consumer.rb

require 'stomp'

module Stp
  class Consumer
    def initialize(options)
      @options = options
      @abonos_queue = options[:abonos_queue]
      @ordenes_queue = options[:ordenes_queue]
    end

    def run
      @client = Stomp::Client.new(
        hosts: [{
          host: @options[:stomp_host],
          port: @options[:stomp_port]
        }],
        connect_headers: { 'client-id': 'stp-ruby' }
      )

      Stp.logger.info 'Connected to ActiveMQ'

      @client.subscribe(@abonos_queue, { ack: 'client' }) do |message|
        Stp.logger.debug "Message received on #{@abonos_queue}"
        Stp.logger.debug message.body

        @client.acknowledge(message)
      end

      Stp.logger.info "Subscribed to #{@abonos_queue}"

      @client.subscribe(@ordenes_queue, { ack: 'client' }) do |message|
        Stp.logger.debug "Message received on #{@ordenes_queue}"
        Stp.logger.debug message.body

        @client.acknowledge(message)
      end

      Stp.logger.info "Subscribed to #{@ordenes_queue}"

      begin
        @client.join
      rescue StandardError => e
        Stp.logger.error e.message
      rescue Interrupt
      rescue SignalException
      ensure
        @client.close

        Stp.logger.info 'Connection closed'
      end
    end
  end
end

stp.gemspec

  spec.bindir        = "bin"
  spec.executables   = ["consumer"]
  spec.add_runtime_dependency "stomp"