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
-
.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.
- .message_processor ⇒ Object
- .table_name_prefix ⇒ Object
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 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 ||= end |
.table_name_prefix ⇒ Object
10 11 12 |
# File 'app/models/renalware/feeds.rb', line 10 def table_name_prefix "feed_" end |