class PubSubModelSync::Connector

Attributes

service[RW]

Public Class Methods

new() click to toggle source
# File lib/pub_sub_model_sync/connector.rb, line 9
def initialize
  @service = build_service
end

Private Instance Methods

build_service() click to toggle source
# File lib/pub_sub_model_sync/connector.rb, line 15
def build_service
  case Config.service_name
  when :google
    PubSubModelSync::ServiceGoogle.new
  when :kafka
    PubSubModelSync::ServiceKafka.new
  else # :rabbit_mq
    PubSubModelSync::ServiceRabbit.new
  end
end