Sha256: adbce046f777c0d86ef007d5b97263c9bc47a75668022c0755d96bd89b37afae
Contents?: true
Size: 692 Bytes
Versions: 62
Compression:
Stored size: 692 Bytes
Contents
# frozen_string_literal: true
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
# Note we are using both the SubscriptionRegistry (which we think is not thread safe)
# as does not store the registry in TLS (?) and also the newer subscription_map
# We need to consolidate these.
def build_message_processor
SubscriptionRegistry
.instance
.subscribe_listeners_to(MessageProcessor.new)
.broadcasting_to_configured_subscribers
end
end
end
Version data entries
62 entries across 62 versions & 1 rubygems