Table of Contents - emque-consuming-1.9.0 Documentation
Pages
- Gemfile.tt
- Rakefile.tt
- application.rb.tt
- development.rb.tt
- production.rb.tt
- staging.rb.tt
- test.rb.tt
- routes.rb.tt
Classes and Modules
- Emque
- Emque::Consuming
- Emque::Consuming::Actor
- Emque::Consuming::Adapter
- Emque::Consuming::AdapterConfigurationError
- Emque::Consuming::Adapters
- Emque::Consuming::Adapters::RabbitMq
- Emque::Consuming::Adapters::RabbitMq::DelayedMessageWorker
- Emque::Consuming::Adapters::RabbitMq::ErrorWorker
- Emque::Consuming::Adapters::RabbitMq::Manager
- Emque::Consuming::Adapters::RabbitMq::Worker
- Emque::Consuming::Application
- Emque::Consuming::BlockingFailure
- Emque::Consuming::Cli
- Emque::Consuming::CommandReceivers
- Emque::Consuming::CommandReceivers::Base
- Emque::Consuming::CommandReceivers::HttpServer
- Emque::Consuming::CommandReceivers::HttpServer::Handler
- Emque::Consuming::CommandReceivers::HttpServer::Logger
- Emque::Consuming::CommandReceivers::UnixSocket
- Emque::Consuming::CommandReceivers::UnixSocket::Handler
- Emque::Consuming::Configuration
- Emque::Consuming::ConfigurationError
- Emque::Consuming::Consumer
- Emque::Consuming::Consumer::Common
- Emque::Consuming::Control
- Emque::Consuming::Control::Errors
- Emque::Consuming::Control::Workers
- Emque::Consuming::Core
- Emque::Consuming::ErrorTracker
- Emque::Consuming::Generators
- Emque::Consuming::Generators::Application
- Emque::Consuming::Helpers
- Emque::Consuming::Logging
- Emque::Consuming::Logging::LogFormatter
- Emque::Consuming::Message
- Emque::Consuming::Pidfile
- Emque::Consuming::RetryableErrors
- Emque::Consuming::Router
- Emque::Consuming::Router::Mapping
- Emque::Consuming::Runner
- Emque::Consuming::Status
- Emque::Consuming::Tasks
- Emque::Consuming::Transmitter
- Object
Methods
- ::config — Emque::Consuming
- ::consumer — Emque::Consuming
- ::default_options — Emque::Consuming::Adapters::RabbitMq
- ::extended — Emque::Consuming::Core
- ::included — Emque::Consuming::Actor
- ::included — Emque::Consuming::Application
- ::included — Emque::Consuming::Consumer::Common
- ::initialize_logger — Emque::Consuming::Logging
- ::load — Emque::Consuming::Adapters::RabbitMq
- ::logger — Emque::Consuming
- ::logger — Emque::Consuming::Logging
- ::logger= — Emque::Consuming
- ::logger= — Emque::Consuming::Logging
- ::manager — Emque::Consuming::Adapters::RabbitMq
- ::method_missing — Emque::Consuming::Transmitter
- ::new — Emque::Consuming::Adapter
- ::new — Emque::Consuming::Adapters::RabbitMq::DelayedMessageWorker
- ::new — Emque::Consuming::Adapters::RabbitMq::ErrorWorker
- ::new — Emque::Consuming::Adapters::RabbitMq::Worker
- ::new — Emque::Consuming::Cli
- ::new — Emque::Consuming::CommandReceivers::HttpServer
- ::new — Emque::Consuming::CommandReceivers::HttpServer::Logger
- ::new — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- ::new — Emque::Consuming::Configuration
- ::new — Emque::Consuming::Control
- ::new — Emque::Consuming::ErrorTracker
- ::new — Emque::Consuming::Generators::Application
- ::new — Emque::Consuming::Pidfile
- ::new — Emque::Consuming::Router
- ::new — Emque::Consuming::Router::Mapping
- ::new — Emque::Consuming::Runner
- ::new — Emque::Consuming::Application
- ::runner — Emque::Consuming
- ::send — Emque::Consuming::Transmitter
- #actor_died — Emque::Consuming::Adapters::RabbitMq::DelayedMessageWorker
- #actor_died — Emque::Consuming::Adapters::RabbitMq::Manager
- #actor_died — Emque::Consuming::Adapters::RabbitMq::Worker
- #app — Emque::Consuming::Runner
- #app — Emque::Consuming::Helpers
- #app_name — Emque::Consuming::CommandReceivers::UnixSocket
- #app_name — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #apply_options — Emque::Consuming::Runner
- #auto_shutdown_enabled — Emque::Consuming::Application
- #bad_request — Emque::Consuming::CommandReceivers::UnixSocket
- #call — Emque::Consuming::CommandReceivers::HttpServer::Handler
- #call — Emque::Consuming::Logging::LogFormatter
- #clear — Emque::Consuming::Control::Errors
- #config — Emque::Consuming::Runner
- #config — Emque::Consuming::Core
- #config — Emque::Consuming::Helpers
- #configuration — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #console — Emque::Consuming::Runner
- #consume — Emque::Consuming::Consumer::Common
- #continue? — Emque::Consuming::Message
- #count — Emque::Consuming::ErrorTracker
- #daemonize! — Emque::Consuming::Runner
- #daemonize? — Emque::Consuming::Runner
- #default_pidfile — Emque::Consuming::Runner
- #delay_ms_time — Emque::Consuming::RetryableErrors
- #delayed_message_exchange — Emque::Consuming::Adapters::RabbitMq::Worker
- #delayed_message_workers — Emque::Consuming::Adapters::RabbitMq::Manager
- #down — Emque::Consuming::Control::Errors
- #down — Emque::Consuming::Control::Workers
- #emque_autoload — Object
- #emque_env — Emque::Consuming::Core
- #enable_delayed_message — Emque::Consuming::Adapters::RabbitMq::Manager
- #enable_delayed_message — Emque::Consuming::Adapters::RabbitMq::Worker
- #ensure_adapter_is_configured! — Emque::Consuming::Application
- #ensure_dir_exists — Emque::Consuming::Pidfile
- #env — Emque::Consuming::Configuration
- #env_var — Emque::Consuming::Configuration
- #error_queue — Emque::Consuming::Adapters::RabbitMq::ErrorWorker
- #errors — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #errors — Emque::Consuming::Control
- #execute — Emque::Consuming::Cli
- #exit_if_already_running! — Emque::Consuming::Runner
- #expire_after — Emque::Consuming::Control::Errors
- #extract_command — Emque::Consuming::Cli
- #fetch_and_load — Emque::Consuming::Adapter
- #generate — Emque::Consuming::Generators::Application
- #get_binding — Emque::Consuming::Generators::Application
- #handle_error — Emque::Consuming::Consumer
- #handle_shutdown — Emque::Consuming::Application
- #help — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #http? — Emque::Consuming::Runner
- #initialize_core! — Emque::Consuming::Core
- #initialize_delayed_message_workers — Emque::Consuming::Adapters::RabbitMq::Manager
- #initialize_environment! — Emque::Consuming::Core
- #initialize_error_queue — Emque::Consuming::Adapters::RabbitMq::Manager
- #initialize_error_tracker — Emque::Consuming::Application
- #initialize_logger — Emque::Consuming::Core
- #initialize_manager — Emque::Consuming::Application
- #initialize_puma — Emque::Consuming::CommandReceivers::HttpServer
- #initialize_router! — Emque::Consuming::Core
- #initialize_workers — Emque::Consuming::Adapters::RabbitMq::Manager
- #install_tasks — Emque::Consuming::Tasks
- #intercept_help — Emque::Consuming::Cli
- #key_for — Emque::Consuming::ErrorTracker
- #limit_reached? — Emque::Consuming::ErrorTracker
- #load_app — Emque::Consuming::Cli
- #load_app! — Emque::Consuming::Core
- #log_error — Emque::Consuming::CommandReceivers::UnixSocket
- #log_formatter — Emque::Consuming::Configuration
- #log_level — Emque::Consuming::Configuration
- #log_prefix — Emque::Consuming::Adapters::RabbitMq::DelayedMessageWorker
- #log_prefix — Emque::Consuming::Adapters::RabbitMq::ErrorWorker
- #log_prefix — Emque::Consuming::Adapters::RabbitMq::Worker
- #log_prefix — Emque::Consuming::Application
- #logfile — Emque::Consuming::Core
- #logger — Emque::Consuming::Core
- #logger — Emque::Consuming::Helpers
- #logger — Emque::Consuming::Logging
- #map — Emque::Consuming::Router
- #map — Emque::Consuming::Router::Mapping
- #middleware? — Emque::Consuming::Router::Mapping
- #new_socket_server — Emque::Consuming::CommandReceivers::UnixSocket
- #new_worker — Emque::Consuming::Adapters::RabbitMq::Manager
- #notice_error — Emque::Consuming::Application
- #notice_error_for — Emque::Consuming::ErrorTracker
- #parse — Emque::Consuming::Consumer
- #parse_options — Emque::Consuming::Cli
- #phased_restart — Emque::Consuming::Runner
- #pipe_config — Emque::Consuming::Consumer::Common
- #process — Emque::Consuming::Consumer
- #process_message — Emque::Consuming::Adapters::RabbitMq::DelayedMessageWorker
- #process_message — Emque::Consuming::Adapters::RabbitMq::Worker
- #publish_to_delayed_message — Emque::Consuming::Adapters::RabbitMq::Worker
- #puts — Emque::Consuming::CommandReceivers::HttpServer::Logger
- #receive_command — Emque::Consuming::CommandReceivers::UnixSocket
- #recent_errors — Emque::Consuming::ErrorTracker
- #recursively_copy_templates — Emque::Consuming::Generators::Application
- #relative_path — Emque::Consuming::Generators::Application
- #render_404 — Emque::Consuming::CommandReceivers::HttpServer::Handler
- #render_status — Emque::Consuming::CommandReceivers::HttpServer::Handler
- #respond — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #respond_to? — Emque::Consuming::Control::Errors
- #respond_to? — Emque::Consuming::Control::Workers
- #restart — Emque::Consuming::CommandReceivers::Base
- #restart — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #restart — Emque::Consuming::Runner
- #restart — Emque::Consuming::Application
- #restart_application — Emque::Consuming::Runner
- #retry — Emque::Consuming::Control::Errors
- #retry_error — Emque::Consuming::RetryableErrors
- #retry_errors — Emque::Consuming::Adapters::RabbitMq::ErrorWorker
- #retry_errors — Emque::Consuming::Adapters::RabbitMq::Manager
- #retry_message — Emque::Consuming::Adapters::RabbitMq::ErrorWorker
- #retryable_error_limit — Emque::Consuming::RetryableErrors
- #retryable_errors — Emque::Consuming::RetryableErrors
- #rm_file — Emque::Consuming::Pidfile
- #route — Emque::Consuming::Consumer
- #route — Emque::Consuming::Router
- #route — Emque::Consuming::Router::Mapping
- #router — Emque::Consuming::Helpers
- #runner — Emque::Consuming::Helpers
- #running? — Emque::Consuming::CommandReceivers::Base
- #running? — Emque::Consuming::Pidfile
- #set_adapter — Emque::Consuming::Configuration
- #set_process_title — Emque::Consuming::Runner
- #setup_connection — Emque::Consuming::Adapters::RabbitMq::Manager
- #setup_options — Emque::Consuming::Cli
- #setup_receivers — Emque::Consuming::Runner
- #sock? — Emque::Consuming::Runner
- #start — Emque::Consuming::Adapters::RabbitMq::DelayedMessageWorker
- #start — Emque::Consuming::Adapters::RabbitMq::Manager
- #start — Emque::Consuming::Adapters::RabbitMq::Worker
- #start — Emque::Consuming::CommandReceivers::Base
- #start — Emque::Consuming::CommandReceivers::HttpServer
- #start — Emque::Consuming::CommandReceivers::UnixSocket
- #start — Emque::Consuming::Runner
- #start — Emque::Consuming::Application
- #status — Emque::Consuming::CommandReceivers::Base
- #status — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #stop — Emque::Consuming::Adapters::RabbitMq::DelayedMessageWorker
- #stop — Emque::Consuming::Adapters::RabbitMq::Manager
- #stop — Emque::Consuming::Adapters::RabbitMq::Worker
- #stop — Emque::Consuming::CommandReceivers::Base
- #stop — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #stop — Emque::Consuming::Runner
- #stop — Emque::Consuming::Actor
- #stop — Emque::Consuming::Application
- #to_h — Emque::Consuming::Configuration
- #to_h — Emque::Consuming::Status
- #to_hsh — Emque::Consuming::Configuration
- #to_hsh — Emque::Consuming::Status
- #topic — Emque::Consuming::Router
- #topic_mapping — Emque::Consuming::Router
- #up — Emque::Consuming::Control::Errors
- #up — Emque::Consuming::Control::Workers
- #use — Emque::Consuming::Router::Mapping
- #valid_request? — Emque::Consuming::CommandReceivers::UnixSocket::Handler
- #verify_error_status — Emque::Consuming::Application
- #with_transmitter — Emque::Consuming::Tasks
- #worker — Emque::Consuming::Adapters::RabbitMq::Manager
- #worker_count — Emque::Consuming::Adapters::RabbitMq::Manager
- #workers — Emque::Consuming::Adapters::RabbitMq::Manager
- #workers — Emque::Consuming::Control
- #workers — Emque::Consuming::Router
- #write — Emque::Consuming::CommandReceivers::HttpServer::Logger
- #write — Emque::Consuming::Pidfile
- #write_pidfile! — Emque::Consuming::Runner