Module: Hsdq

Includes:

Admin, Connectors, Listener, Receiver, Sender, Session, Setting, Shared, ThreadStore, Threadpool, Utilities

Defined in:

lib/hsdq.rb,
lib/hsdq/admin.rb,
lib/hsdq/sender.rb,
lib/hsdq/shared.rb,
lib/hsdq/session.rb,
lib/hsdq/setting.rb,
lib/hsdq/version.rb,
lib/hsdq/listener.rb,
lib/hsdq/receiver.rb,
lib/hsdq/utilities.rb,
lib/hsdq/connectors.rb,
lib/hsdq/threadpool.rb,
lib/hsdq/thread_store.rb

Defined Under Namespace

Modules: Admin, Connectors, Listener, Receiver, Sender, Session, Setting, Shared, ThreadStore, Threadpool, Utilities

Constant Summary

VERSION =

"0.7.0"

Instance Method Summary

• #hsdq_version ⇒ Object

Methods included from Admin

#admin_channel, #admin_channels, #admin_id_channel, #admin_listener, #admin_versionned_channel, #listener_id, #listener_version, #process_admin_message

Methods included from Threadpool

#allow_new_threads?, #hsdq_start_thread, #hsdq_threads, #hsdq_threads_add, #hsdq_threads_count, #max_thread_count, #paused, #paused?

Methods included from Session

#hsdq_session, #hsdq_session_del, #hsdq_session_destroy, #hsdq_session_expire, #hsdq_session_expire_in, #hsdq_session_key?, #hsdq_session_set

Methods included from ThreadStore

#context, #context_params, #current_uid, #previous_sender, #reply_to, #sent_to, #set_get

Methods included from Receiver

#check_whitelist, #get_burst, #get_spark, #h_spark, #hsdq_ack, #hsdq_add_authorized_tasks, #hsdq_add_authorized_topics, #hsdq_authorized_tasks, #hsdq_authorized_topics, #hsdq_authorized_types, #hsdq_callback, #hsdq_error, #hsdq_feedback, #hsdq_ignit, #hsdq_request, #hsdq_set_authorized_tasks, #hsdq_set_authorized_topics, #pull_burst, #pull_burst_only, #reject_spark, #response?, #send_ack, #set_context, #sparkle, #valid_spark?, #valid_task?, #valid_topic?, #whitelisted?

Methods included from Setting

#channel, #channel=, #config_file_path, #config_filename, #config_path, #cx_opts, #default_opts, #environment, #environment_from_app, #hsdq_add_options, #hsdq_get_name, #hsdq_opts, #initial_setup, #read_opts, #set_abort_on_exception

Methods included from Sender

#build_spark, #hsdq_send, #hsdq_send_ack, #hsdq_send_callback, #hsdq_send_error, #hsdq_send_feedback, #hsdq_send_request, #prepare_message, #send_message, #valid_keys?

Methods included from Connectors

#cx_admin, #cx_data, #cx_listener, #cx_session

Methods included from Listener

#hsdq_alive?, #hsdq_exit!, #hsdq_exit?, #hsdq_running?, #hsdq_start, #hsdq_start!, #hsdq_stop!, #hsdq_stopped?, #kill_alive!, #start_listener

Methods included from Utilities

#deep_symbolize, #snakify

Methods included from Shared

#burst_key, #hsdq_key, #placeholder, #session_key, #valid_type?

Instance Method Details

#hsdq_version ⇒ Object

# File 'lib/hsdq/version.rb', line 4

def hsdq_version
  VERSION
end