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