Method List

Classes Methods Files

Search:

#<< MessageBus::Client
#add MessageBus::Memory::Client
#add MessageBus::Postgres::Client
#add_client MessageBus::ConnectionManager
#add_client_with_timeout MessageBus::Rack::Middleware
#after_fork MessageBus::Redis::ReliablePubSub
#after_fork MessageBus::Memory::ReliablePubSub
#after_fork MessageBus::Implementation
#after_fork MessageBus::Postgres::ReliablePubSub
#allow_broadcast= MessageBus::Implementation
#allow_broadcast? MessageBus::Implementation
#allowed? MessageBus::Client
#api_only? MessageBus::Rails::Railtie
#asset_contents MessageBus::Rack::Diagnostics
#asset_path MessageBus::Rack::Diagnostics
#async_response MessageBus::Client
#backend MessageBus::Memory::ReliablePubSub
#backend MessageBus::Postgres::ReliablePubSub
#backend MessageBus::Implementation
#backlog MessageBus::Postgres::ReliablePubSub
#backlog MessageBus::Redis::ReliablePubSub
#backlog MessageBus::Client
#backlog MessageBus::Postgres::Client
#backlog MessageBus::Implementation
#backlog MessageBus::Memory::Client
#backlog MessageBus::Memory::ReliablePubSub
#backlog_id_key MessageBus::Redis::ReliablePubSub
#backlog_key MessageBus::Redis::ReliablePubSub
backlog_to_json MessageBus::Rack::Middleware
#blocking_subscribe MessageBus::Implementation
#cache_assets MessageBus::Implementation
#cache_assets= MessageBus::Implementation
#call Thin::DeferrableBody
#call MessageBus::Rack::Middleware
#call MessageBus::Rack::Diagnostics
#callback Thin::AsyncResponse
#cancel MessageBus::TimerThread::Cancelable
#cancel MessageBus::TimerThread::CancelableEvery
#cancel MessageBus::Client
#cancelled MessageBus::TimerThread::CancelableEvery
#channel MessageBus::Message
#chunked_encoding_enabled= MessageBus::Implementation
#chunked_encoding_enabled? MessageBus::Implementation
#cleanup_timer MessageBus::Client
#clear_channel_backlog MessageBus::Postgres::Client
#clear_channel_backlog MessageBus::Memory::Client
#clear_every MessageBus::Memory::ReliablePubSub
#clear_every MessageBus::Postgres::ReliablePubSub
#clear_global_backlog MessageBus::Postgres::Client
#clear_global_backlog MessageBus::Memory::Client
#client MessageBus::Postgres::ReliablePubSub
#client MessageBus::Memory::ReliablePubSub
#client_count MessageBus::ConnectionManager
#client_id MessageBus::Client
#client_ids MessageBus::Message
#close MessageBus::Client
#close_db_connection! MessageBus::Rack::Middleware
#closed Thin::AsyncResponse
#closed? MessageBus::Client
#config MessageBus::Implementation
#configure MessageBus::Implementation
#connect_time MessageBus::Client
#current MessageBus::TimerThread::CancelableEvery
#data MessageBus::Message
decode MessageBus::Message
#decode_channel_name MessageBus::Implementation
#deliver_backlog MessageBus::Client
#destroy MessageBus::Implementation
#do_message MessageBus::Postgres::Client::Listener
#do_message MessageBus::Memory::Client::Listener
#do_sub MessageBus::Memory::Client::Listener
#do_sub MessageBus::Postgres::Client::Listener
#do_unsub MessageBus::Memory::Client::Listener
#do_unsub MessageBus::Postgres::Client::Listener
#done Thin::AsyncResponse
#each Thin::DeferrableBody
enable MessageBus::Diagnostics
#enable_diagnostics MessageBus::Implementation
#encode MessageBus::Message
#encode_channel_name MessageBus::Implementation
#encode_without_ids MessageBus::Message
#ensure_backlog_flushed MessageBus::Redis::ReliablePubSub
#ensure_closed! MessageBus::Client
#ensure_first_chunk_sent MessageBus::Client
#every MessageBus::TimerThread
#expire MessageBus::Postgres::Client
#extra_response_headers_lookup MessageBus::Implementation
#file_hash MessageBus::Rack::Diagnostics
#flash_middleware_deleted? MessageBus::Rails::Railtie
full_process_path MessageBus::Diagnostics
#generate_script_tag MessageBus::Rack::Diagnostics
#get_message MessageBus::Postgres::ReliablePubSub
#get_message MessageBus::Redis::ReliablePubSub
#get_message MessageBus::Memory::ReliablePubSub
#get_value MessageBus::Postgres::Client
#get_value MessageBus::Memory::Client
#global_backlog MessageBus::Memory::ReliablePubSub
#global_backlog MessageBus::Implementation
#global_backlog MessageBus::Postgres::ReliablePubSub
#global_backlog MessageBus::Postgres::Client
#global_backlog MessageBus::Memory::Client
#global_backlog MessageBus::Redis::ReliablePubSub
#global_backlog_key MessageBus::Redis::ReliablePubSub
#global_id MessageBus::Message
#global_id_key MessageBus::Redis::ReliablePubSub
#global_subscribe MessageBus::Redis::ReliablePubSub
#global_subscribe MessageBus::Memory::ReliablePubSub
#global_subscribe MessageBus::Postgres::ReliablePubSub
#global_unsubscribe MessageBus::Postgres::ReliablePubSub
#global_unsubscribe MessageBus::Redis::ReliablePubSub
#global_unsubscribe MessageBus::Memory::ReliablePubSub
#group_ids MessageBus::Message
#group_ids MessageBus::Client
#group_ids_lookup MessageBus::Implementation
#headers Thin::AsyncResponse
#headers MessageBus::Client
#highest_id MessageBus::Redis::ReliablePubSub::BackLogOutOfOrder
hostname MessageBus::Diagnostics
#in_async? MessageBus::Client
#indent MessageBus::Rack::Diagnostics
#index MessageBus::Rack::Diagnostics
#initialize Thin::DeferrableBody
#initialize MessageBus::TimerThread::Cancelable
#initialize MessageBus::TimerThread
#initialize MessageBus::Memory::ReliablePubSub
#initialize MessageBus::Memory::Client
#initialize MessageBus::Rack::Middleware
#initialize MessageBus::Client
#initialize MessageBus::Postgres::Client
#initialize MessageBus::ConnectionManager
#initialize MessageBus::Implementation
#initialize MessageBus::Postgres::ReliablePubSub
#initialize MessageBus::Redis::ReliablePubSub
#initialize MessageBus::Redis::ReliablePubSub::BackLogOutOfOrder
#initialize MessageBus::Rack::Diagnostics
#initialize Thin::AsyncResponse
#io MessageBus::Client
#is_admin_lookup MessageBus::Implementation
#jobs MessageBus::TimerThread
#js_asset MessageBus::Rack::Diagnostics
#keepalive_interval MessageBus::Implementation
#keepalive_interval= MessageBus::Implementation
#last_id MessageBus::Implementation
#last_id MessageBus::Postgres::ReliablePubSub
#last_id MessageBus::Memory::ReliablePubSub
#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
#max_backlog_age MessageBus::Postgres::ReliablePubSub
#max_backlog_age MessageBus::Redis::ReliablePubSub
#max_backlog_size MessageBus::Postgres::ReliablePubSub
#max_backlog_size MessageBus::Redis::ReliablePubSub
#max_backlog_size MessageBus::Memory::ReliablePubSub
#max_global_backlog_size MessageBus::Postgres::ReliablePubSub
#max_global_backlog_size MessageBus::Redis::ReliablePubSub
#max_global_backlog_size MessageBus::Memory::ReliablePubSub
#max_id MessageBus::Postgres::Client
#max_id MessageBus::Memory::Client
#max_in_memory_publish_backlog MessageBus::Redis::ReliablePubSub
#message MessageBus::Postgres::Client::Listener
#message MessageBus::Memory::Client::Listener
#message_id MessageBus::Message
#new_connection MessageBus::Postgres::ReliablePubSub
#new_connection MessageBus::Memory::ReliablePubSub
#new_redis_connection MessageBus::Redis::ReliablePubSub
#notify_clients MessageBus::ConnectionManager
#off MessageBus::Implementation
#on MessageBus::Implementation
#on_connect MessageBus::Implementation
#on_disconnect MessageBus::Implementation
#on_error MessageBus::TimerThread
#on_middleware_error MessageBus::Implementation
#postgresql_channel_name MessageBus::Postgres::ReliablePubSub
#process_global_backlog MessageBus::Memory::ReliablePubSub
#process_global_backlog MessageBus::Redis::ReliablePubSub
#process_global_backlog MessageBus::Postgres::ReliablePubSub
#pub_redis MessageBus::Redis::ReliablePubSub
#publish MessageBus::Memory::ReliablePubSub
#publish MessageBus::Redis::ReliablePubSub
#publish MessageBus::Postgres::Client
#publish MessageBus::Implementation
#publish MessageBus::Postgres::ReliablePubSub
#queue MessageBus::TimerThread
#rack_hijack_enabled= MessageBus::Implementation
#rack_hijack_enabled? MessageBus::Implementation
reactor_pid EM
#reconnect MessageBus::Postgres::Client
#redis_channel_name MessageBus::Redis::ReliablePubSub
#redis_config= MessageBus::Implementation
#reliable_pub_sub MessageBus::Implementation
#reliable_pub_sub= MessageBus::Implementation
#remove_client MessageBus::ConnectionManager
#reset! MessageBus::Memory::ReliablePubSub
reset! MessageBus::Postgres::ReliablePubSub
#reset! MessageBus::Memory::Client
#reset! MessageBus::Redis::ReliablePubSub
#reset! MessageBus::Postgres::ReliablePubSub
#reset! MessageBus::Implementation
#reset! MessageBus::Postgres::Client
#send_headers Thin::AsyncResponse
#seq MessageBus::Client
#site_id MessageBus::Message
#site_id MessageBus::Client
#site_id_lookup MessageBus::Implementation
#start_listener MessageBus::Rack::Middleware
#stats MessageBus::ConnectionManager
#status Thin::AsyncResponse
#stop MessageBus::TimerThread
#stop_listener MessageBus::Rack::Middleware
#subscribe MessageBus::Memory::Client
#subscribe MessageBus::Redis::ReliablePubSub
#subscribe MessageBus::Memory::Client::Listener
#subscribe MessageBus::Postgres::ReliablePubSub
#subscribe MessageBus::Client
#subscribe MessageBus::Implementation
#subscribe MessageBus::Postgres::Client
#subscribe MessageBus::Postgres::Client::Listener
#subscribe MessageBus::Memory::ReliablePubSub
#subscribe_client MessageBus::ConnectionManager
#subscribed MessageBus::Memory::ReliablePubSub
#subscribed MessageBus::Redis::ReliablePubSub
#subscribed MessageBus::Postgres::ReliablePubSub
#subscribed_sets MessageBus::Client
#subscriptions MessageBus::Client
#synchronize MessageBus::Client
#timer MessageBus::Implementation
#translate_handlebars MessageBus::Rack::Diagnostics
#unsubscribe MessageBus::Memory::Client
#unsubscribe MessageBus::Memory::Client::Listener
#unsubscribe MessageBus::Implementation
#unsubscribe MessageBus::Postgres::Client::Listener
#unsubscribe MessageBus::Postgres::Client
#use_chunked MessageBus::Client
#user_id MessageBus::Client
#user_id_lookup MessageBus::Implementation
#user_ids MessageBus::Message
#write Thin::AsyncResponse