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/models/renalware/feeds/hl7_test_form.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/hl7_test_message.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/tissue_typing/import.rb,
app/controllers/renalware/feeds/hl7_test_messages_controller.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: DuplicateMessageError, File, FilePolicy, FileType, HL7Message, HL7TestForm, HL7TestMessage, HL7TestMessagesController, 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.



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

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

.message_processor ⇒ Object 



16
17
18
 
# File 'app/models/renalware/feeds.rb', line 16

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