Table of Contents - message_bus-1.0.16 Documentation
Classes and Modules
- EM
- MessageBus
- MessageBus::BusDestroyed
- MessageBus::Client
- MessageBus::ConnectionManager
- MessageBus::ConnectionManager::SynchronizedSet
- MessageBus::Diagnostics
- MessageBus::Implementation
- MessageBus::Implementation::Synchronizer
- MessageBus::Instance
- MessageBus::InvalidMessage
- MessageBus::Message
- MessageBus::MessageHandler
- MessageBus::Rack
- MessageBus::Rack::Diagnostics
- MessageBus::Rack::Middleware
- MessageBus::Rails
- MessageBus::Rails::Engine
- MessageBus::Rails::Railtie
- MessageBus::Rails::Railtie::ActionDispatch
- MessageBus::Redis
- MessageBus::Redis::ReliablePubSub
- MessageBus::Redis::ReliablePubSub::BackLogOutOfOrder
- MessageBus::Redis::ReliablePubSub::NoMoreRetries
- MessageBus::TimerThread
- MessageBus::TimerThread::Cancelable
- MessageBus::TimerThread::CancelableEvery
- Thin
- Thin::AsyncResponse
- Thin::DeferrableBody
Methods
- ::backlog_to_json — MessageBus::Rack::Middleware
- ::call — MessageBus::MessageHandler
- ::decode — MessageBus::Message
- ::enable — MessageBus::Diagnostics
- ::full_process_path — MessageBus::Diagnostics
- ::handle — MessageBus::MessageHandler
- ::hostname — MessageBus::Diagnostics
- ::load_handlers — MessageBus::MessageHandler
- ::new — MessageBus::Rack::Middleware
- ::new — Thin::AsyncResponse
- ::new — Thin::DeferrableBody
- ::new — MessageBus::Rack::Diagnostics
- ::new — MessageBus::Redis::ReliablePubSub
- ::new — MessageBus::ConnectionManager
- ::new — MessageBus::Redis::ReliablePubSub::BackLogOutOfOrder
- ::new — MessageBus::TimerThread
- ::new — MessageBus::TimerThread::Cancelable
- ::new — MessageBus::Implementation
- ::new — MessageBus::ConnectionManager::SynchronizedSet
- ::new — MessageBus::Client
- ::reactor_pid — EM
- ::synchronize — MessageBus::ConnectionManager::SynchronizedSet
- #<< — Thin::AsyncResponse
- #<< — MessageBus::Client
- #add_client — MessageBus::ConnectionManager
- #add_client_with_timeout — MessageBus::Rack::Middleware
- #after_fork — MessageBus::Redis::ReliablePubSub
- #after_fork — MessageBus::Implementation
- #allow_broadcast= — MessageBus::Implementation
- #allow_broadcast? — MessageBus::Implementation
- #allowed? — MessageBus::Client
- #around_client_batch — MessageBus::Implementation
- #asset_contents — MessageBus::Rack::Diagnostics
- #asset_path — MessageBus::Rack::Diagnostics
- #backlog — MessageBus::Client
- #backlog — MessageBus::Implementation
- #backlog — MessageBus::Redis::ReliablePubSub
- #backlog_id_key — MessageBus::Redis::ReliablePubSub
- #backlog_key — MessageBus::Redis::ReliablePubSub
- #blocking_subscribe — MessageBus::Implementation
- #cache_assets — MessageBus::Implementation
- #cache_assets= — MessageBus::Implementation
- #call — MessageBus::Rack::Diagnostics
- #call — Thin::DeferrableBody
- #call — MessageBus::Rack::Middleware
- #cancel — MessageBus::TimerThread::CancelableEvery
- #cancel — MessageBus::TimerThread::Cancelable
- #client_count — MessageBus::ConnectionManager
- #client_filter — MessageBus::Implementation
- #close — MessageBus::Client
- #close_db_connection! — MessageBus::Rack::Middleware
- #closed — MessageBus::Client
- #decode_channel_name — MessageBus::Implementation
- #decode_message! — MessageBus::Implementation
- #destroy — MessageBus::Implementation
- #do_work — MessageBus::TimerThread
- #done — Thin::AsyncResponse
- #each — Thin::DeferrableBody
- #enable_diagnostics — MessageBus::Implementation
- #encode — MessageBus::Message
- #encode_channel_name — MessageBus::Implementation
- #ensure_backlog_flushed — MessageBus::Redis::ReliablePubSub
- #ensure_closed! — MessageBus::Client
- #ensure_subscriber_thread — MessageBus::Implementation
- #every — MessageBus::TimerThread
- #extra_response_headers_lookup — MessageBus::Implementation
- #file_hash — MessageBus::Rack::Diagnostics
- #filter — MessageBus::Client
- #generate_script_tag — MessageBus::Rack::Diagnostics
- #get_message — MessageBus::Redis::ReliablePubSub
- #global? — MessageBus::Implementation
- #global_backlog — MessageBus::Redis::ReliablePubSub
- #global_backlog — MessageBus::Implementation
- #global_backlog_key — MessageBus::Redis::ReliablePubSub
- #global_id_key — MessageBus::Redis::ReliablePubSub
- #global_subscribe — MessageBus::Redis::ReliablePubSub
- #global_subscribe_thread — MessageBus::Implementation
- #global_unsubscribe — MessageBus::Redis::ReliablePubSub
- #group_ids_lookup — MessageBus::Implementation
- #in_async? — MessageBus::Client
- #indent — MessageBus::Rack::Diagnostics
- #index — MessageBus::Rack::Diagnostics
- #is_admin_lookup — MessageBus::Implementation
- #js_asset — MessageBus::Rack::Diagnostics
- #keepalive_interval — MessageBus::Implementation
- #keepalive_interval= — MessageBus::Implementation
- #last_id — MessageBus::Implementation
- #last_id — MessageBus::Redis::ReliablePubSub
- #last_message — MessageBus::Implementation
- #listening? — MessageBus::Implementation
- #local_subscribe — MessageBus::Implementation
- #local_unsubscribe — MessageBus::Implementation
- #logger — MessageBus::Implementation
- #logger= — MessageBus::Implementation
- #long_polling_enabled= — MessageBus::Implementation
- #long_polling_enabled? — MessageBus::Implementation
- #long_polling_interval — MessageBus::Implementation
- #long_polling_interval= — MessageBus::Implementation
- #lookup_client — MessageBus::ConnectionManager
- #max_active_clients — MessageBus::Implementation
- #max_active_clients= — MessageBus::Implementation
- #messages_to_json — MessageBus::Client
- #multi_each — MessageBus::Implementation
- #new_redis_connection — MessageBus::Redis::ReliablePubSub
- #new_subscriber_thread — MessageBus::Implementation
- #notify_clients — MessageBus::ConnectionManager
- #off — MessageBus::Implementation
- #on — MessageBus::Implementation
- #on_connect — MessageBus::Implementation
- #on_disconnect — MessageBus::Implementation
- #on_error — MessageBus::TimerThread
- #process_global_backlog — MessageBus::Redis::ReliablePubSub
- #pub_redis — MessageBus::Redis::ReliablePubSub
- #publish — MessageBus::Redis::ReliablePubSub
- #publish — MessageBus::Implementation
- #queue — MessageBus::TimerThread
- #rack_hijack_enabled= — MessageBus::Implementation
- #rack_hijack_enabled? — MessageBus::Implementation
- #redis_channel_name — MessageBus::Redis::ReliablePubSub
- #redis_config — MessageBus::Implementation
- #redis_config= — MessageBus::Implementation
- #reliable_pub_sub — MessageBus::Implementation
- #reliable_pub_sub= — MessageBus::Implementation
- #remove_client — MessageBus::ConnectionManager
- #reset! — MessageBus::Implementation
- #reset! — MessageBus::Redis::ReliablePubSub
- #schedule_dequeue — Thin::DeferrableBody
- #send_headers — Thin::AsyncResponse
- #site_id_lookup — MessageBus::Implementation
- #start_listener — MessageBus::Rack::Middleware
- #stats — MessageBus::ConnectionManager
- #stop — MessageBus::TimerThread
- #stop_listener — MessageBus::Rack::Middleware
- #subscribe — MessageBus::Client
- #subscribe — MessageBus::Implementation
- #subscribe — MessageBus::Redis::ReliablePubSub
- #subscribe_client — MessageBus::ConnectionManager
- #subscribe_impl — MessageBus::Implementation
- #subscriptions — MessageBus::Client
- #timer — MessageBus::Implementation
- #translate_handlebars — MessageBus::Rack::Diagnostics
- #unsubscribe — MessageBus::Implementation
- #unsubscribe_impl — MessageBus::Implementation
- #user_id_lookup — MessageBus::Implementation
- #write — Thin::AsyncResponse
- #write_and_close — MessageBus::Client