Sha256: 77676e4655dd6c7e0e1d77fa5074e737481f2661de1014cd4eeeead6d678b1f7
Contents?: true
Size: 403 Bytes
Versions: 28
Compression:
Stored size: 403 Bytes
Contents
require_dependency "renalware"
require "subscription_registry"
module Renalware
module Feeds
module_function
def table_name_prefix
"feed_"
end
def message_processor
@message_processor ||= build_message_processor
end
def build_message_processor
SubscriptionRegistry
.instance
.subscribe_listeners_to(MessageProcessor.new)
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems