Module: Renalware::Feeds

Defined in:
app/models/renalware/feeds.rb,
app/models/renalware/feeds/file.rb,
app/models/renalware/feeds/message.rb,
app/models/renalware/feeds/file_type.rb,
app/models/renalware/feeds/hl7_message.rb,
app/models/concerns/renalware/feeds/job.rb,
app/policies/renalware/feeds/file_policy.rb,
app/models/renalware/feeds/message_parser.rb,
app/models/renalware/feeds/persist_message.rb,
app/models/renalware/feeds/files/exceptions.rb,
app/models/renalware/feeds/message_processor.rb,
app/models/renalware/feeds/files/create_feed_file.rb,
app/models/renalware/feeds/files/file_upload_form.rb,
app/models/renalware/feeds/files/import_job_factory.rb,
app/models/renalware/feeds/files/practices/csv_file.rb,
app/models/renalware/feeds/files/practices/import_csv.rb,
app/models/renalware/feeds/files/practices/import_job.rb,
app/models/renalware/feeds/files/practices/xml_parser.rb,
app/models/renalware/feeds/files/tissue_typing/import.rb,
app/models/renalware/feeds/files/practices/country_map.rb,
app/models/renalware/feeds/files/practices/csv_organisation.rb,
app/models/renalware/feeds/files/practices/convert_xml_to_csv.rb,
app/models/renalware/feeds/files/practice_memberships/import_csv.rb,
app/models/renalware/feeds/files/practice_memberships/import_job.rb,
app/models/renalware/feeds/files/primary_care_physicians/import_csv.rb,
app/models/renalware/feeds/files/primary_care_physicians/import_job.rb,
app/models/renalware/feeds/files/enqueue_file_for_background_processing.rb

Defined Under Namespace

Modules: Files, Job Classes: File, FilePolicy, FileType, HL7Message, Message, MessageParser, MessageProcessor, PersistMessage

Class Method Summary collapse

Class Method Details

.build_message_processor ⇒ Object

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.



21
22
23
24
25
26
 
# File 'app/models/renalware/feeds.rb', line 21

def build_message_processor
  SubscriptionRegistry
    .instance
    .subscribe_listeners_to(MessageProcessor.new)
    .broadcasting_to_configured_subscribers
end

.message_processor ⇒ Object 



14
15
16
 
# File 'app/models/renalware/feeds.rb', line 14

def message_processor
  @message_processor ||= build_message_processor
end

.table_name_prefix ⇒ Object 



10
11
12
 
# File 'app/models/renalware/feeds.rb', line 10

def table_name_prefix
  "feed_"
end