Class: OpenWFE::ThreadedYamlFileExpressionStorage

Inherits:

YamlFileExpressionStorage

• Object
• YamlFileStorage
• YamlFileExpressionStorage
• OpenWFE::ThreadedYamlFileExpressionStorage

Includes:

ThreadedStorageMixin

Defined in:

lib/openwfe/expool/yamlexpstorage.rb

Overview

With this extension of YmalFileExpressionStorage, persistence occurs in a separate thread, for a snappier response.

Constant Summary

Constants included from ThreadedStorageMixin

OpenWFE::ThreadedStorageMixin::THREADED_FREQ

Instance Attribute Summary

Attributes inherited from YamlFileStorage

#basepath

Attributes included from ServiceMixin

#service_name

Attributes included from Contextual

#application_context

Instance Method Summary

• #initialize(service_name, application_context) ⇒ ThreadedYamlFileExpressionStorage constructor

  A new instance of ThreadedYamlFileExpressionStorage.

Methods included from ThreadedStorageMixin

#find_expressions, #stop

Methods inherited from YamlFileExpressionStorage

#fetch_root, #find_expressions, split_file_path, #to_s

Methods included from ExpressionStorageBase

#class_accepted?, #does_match?, #observe_expool, #to_s

Methods included from OwfeServiceLocator

#get_engine, #get_error_journal, #get_expool, #get_expression_map, #get_expression_pool, #get_expression_storage, #get_expression_storages, #get_journal, #get_participant_map, #get_scheduler, #get_wfid_generator

Methods inherited from YamlFileStorage

#[], #[]=, #delete, #has_key?, #length, #purge

Methods included from ServiceMixin

#service_init, #stop

Methods included from Contextual

#get_work_directory, #init_service, #lookup

Methods included from Logging

#ldebug, #ldebug_callstack, #lerror, #lfatal, #linfo, #llog, #lunknown, #lwarn

Constructor Details

#initialize(service_name, application_context) ⇒ ThreadedYamlFileExpressionStorage

Returns a new instance of ThreadedYamlFileExpressionStorage.

# File 'lib/openwfe/expool/yamlexpstorage.rb', line 214

def initialize (service_name, application_context)

    super

    start_processing_thread
        #
        # which sets @thread_id
end