Sha256: 5eff9a9530e704bf637fa15063610579a1bfc87589b376b3296c85099f531f84
Contents?: true
Size: 716 Bytes
Versions: 5
Compression:
Stored size: 716 Bytes
Contents
# frozen_string_literal: true module PubSubModelSync class Config cattr_accessor(:listeners) { [] } cattr_accessor(:publishers) { [] } cattr_accessor(:service_name) { :google } cattr_accessor :logger # google service cattr_accessor :project, :credentials, :topic_name, :subscription_name # rabbitmq service cattr_accessor :bunny_connection, :queue_name, :topic_name # kafka service cattr_accessor :kafka_connection, :topic_name def self.log(msg, kind = :info) msg = "PS_MSYNC ==> #{msg}" if logger == :raise_error kind == :error ? raise(msg) : puts(msg) else logger ? logger.send(kind, msg) : puts(msg) end end end end
Version data entries
5 entries across 5 versions & 1 rubygems