Contents

require 'bunny'

module GeoConcerns
  class RabbitMessagingClient
    attr_reader :amqp_url
    def initialize(amqp_url)
      @amqp_url = amqp_url
    end

    def publish(message)
      exchange_type = JSON.parse(message)['exchange']
      send(exchange_type)
      @exchange.publish(message, persistent: true)
    rescue
      Rails.logger.warn "Unable to publish message to #{amqp_url}"
    end

    def geoblacklight
      exchange_name = GeoConcerns::Messaging.config['events']['exchange']['geoblacklight']
      @exchange ||= channel.fanout(exchange_name, durable: true)
    end

    def geoserver
      exchange_name = GeoConcerns::Messaging.config['events']['exchange']['geoserver']
      @exchange ||= channel.fanout(exchange_name, durable: true)
    end

    private

      def bunny_client
        @bunny_client ||= Bunny.new(amqp_url).tap(&:start)
      end

      def channel
        @channel ||= bunny_client.create_channel
      end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
geo_concerns-0.3.4	app/services/geo_concerns/rabbit_messaging_client.rb
geo_concerns-0.3.3	app/services/geo_concerns/rabbit_messaging_client.rb
geo_concerns-0.3.2	app/services/geo_concerns/rabbit_messaging_client.rb
geo_concerns-0.3.1	app/services/geo_concerns/rabbit_messaging_client.rb
geo_concerns-0.3.0	app/services/geo_concerns/rabbit_messaging_client.rb
geo_concerns-0.2.0	app/services/geo_concerns/rabbit_messaging_client.rb