Contents

# frozen_string_literal: true

require 'google/cloud/pubsub'
module PubSubModelSync
  class Connector
    attr_accessor :service
    delegate :listen_messages, :publish, :stop, to: :service

    def initialize
      @service = build_service
    end

    private

    def build_service
      case Config.service_name
      when :google
        PubSubModelSync::ServiceGoogle.new
      else # :rabbit_mq
        PubSubModelSync::ServiceRabbit.new
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
pub_sub_model_sync-0.1.4	lib/pub_sub_model_sync/connector.rb
pub_sub_model_sync-0.1.3	lib/pub_sub_model_sync/connector.rb
pub_sub_model_sync-0.1.2	lib/pub_sub_model_sync/connector.rb
pub_sub_model_sync-0.1.1	lib/pub_sub_model_sync/connector.rb