Method List

Classes Methods Files

Search:

#<< MessageBus::Client
#[] MessageBus::DistributedCache
#[]= MessageBus::DistributedCache
#add MessageBus::Backends::Postgres::Client
#add MessageBus::Backends::Memory::Client
#add_client MessageBus::ConnectionManager
#after_fork MessageBus::Backends::Postgres::Client
#after_fork MessageBus::Backends::Redis
#after_fork MessageBus::Backends::Postgres
#after_fork MessageBus::Backends::Base
#after_fork MessageBus::Backends::Memory
#after_fork MessageBus::Implementation
#allow_broadcast= MessageBus::Implementation
#allow_broadcast? MessageBus::Implementation
#allowed? MessageBus::Client
#api_only? MessageBus::Rails::Railtie
#app_version MessageBus::DistributedCache::Manager
#async_response MessageBus::Client
#backend MessageBus::Implementation
#backend_instance MessageBus::Implementation
#backend_instance= MessageBus::Implementation
#background_callback_interval MessageBus::HTTPClient
#backlog MessageBus::Backends::Redis
#backlog MessageBus::Backends::Postgres
#backlog MessageBus::Backends::Postgres::Client
#backlog MessageBus::Backends::Memory
#backlog MessageBus::Backends::Memory::Client::Channel
#backlog MessageBus::Backends::Base
#backlog MessageBus::Implementation
#backlog MessageBus::Backends::Memory::Client
#backlog MessageBus::Client
backlog_to_json MessageBus::Rack::Middleware
#base_route MessageBus::Implementation
#base_route= MessageBus::Implementation
#blocking_subscribe MessageBus::Implementation
#call MessageBus::TimerThread::Cancelable::NoOp
#call Thin::DeferrableBody
#call MessageBus::Rack::Middleware
#callback Thin::AsyncResponse
#callbacks MessageBus::HTTPClient::Channel
#cancel MessageBus::TimerThread::Cancelable
#cancel MessageBus::TimerThread::CancelableEvery
#cancelled MessageBus::TimerThread::CancelableEvery
#channel MessageBus::Message
#channels MessageBus::HTTPClient
#chunked_encoding_enabled= MessageBus::Implementation
#chunked_encoding_enabled? MessageBus::Implementation
#cleanup_timer MessageBus::Client
#clear MessageBus::DistributedCache::Manager
#clear MessageBus::DistributedCache
#clear_channel_backlog MessageBus::Backends::Postgres::Client
#clear_channel_backlog MessageBus::Backends::Memory::Client
#clear_every MessageBus::Backends::Base
#clear_global_backlog MessageBus::Backends::Postgres::Client
#clear_global_backlog MessageBus::Backends::Memory::Client
#client_count MessageBus::ConnectionManager
#client_id MessageBus::Client
#client_ids MessageBus::Message
#client_message_filters MessageBus::Implementation
#close MessageBus::Client
#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::Codec::Json
#decode MessageBus::Codec::Base
#decode MessageBus::Codec::Oj
decode MessageBus::Message
default_manager MessageBus::DistributedCache
#delete MessageBus::DistributedCache
#delete MessageBus::DistributedCache::Manager
#deliver_backlog MessageBus::Client
#destroy MessageBus::Backends::Postgres
#destroy MessageBus::Implementation
#destroy MessageBus::Backends::Base
#destroy MessageBus::Backends::Postgres::Client
#destroy MessageBus::Backends::Memory
#destroy MessageBus::Backends::Redis
#do_message MessageBus::Backends::Memory::Client::Listener
#do_message MessageBus::Backends::Postgres::Client::Listener
#do_sub MessageBus::Backends::Postgres::Client::Listener
#do_sub MessageBus::Backends::Memory::Client::Listener
#do_unsub MessageBus::Backends::Memory::Client::Listener
#do_unsub MessageBus::Backends::Postgres::Client::Listener
#done Thin::AsyncResponse
#each Thin::DeferrableBody
#enable_chunked_encoding MessageBus::HTTPClient
#enable_long_polling MessageBus::HTTPClient
#encode MessageBus::Codec::Oj
#encode MessageBus::Codec::Json
#encode MessageBus::Codec::Base
#encode MessageBus::Message
#encode_without_ids MessageBus::Message
#ensure_first_chunk_sent MessageBus::Client
#ensure_subscribe! MessageBus::DistributedCache::Manager
#every MessageBus::TimerThread
#expire MessageBus::Backends::Memory::Client
#expire MessageBus::Backends::Postgres::Client
#expire_all_backlogs! MessageBus::Backends::Redis
#expire_all_backlogs! MessageBus::Backends::Postgres
#expire_all_backlogs! MessageBus::Backends::Base
#expire_all_backlogs! MessageBus::Backends::Postgres::Client
#expire_all_backlogs! MessageBus::Backends::Memory
#expire_all_backlogs! MessageBus::Backends::Memory::Client
#expired? MessageBus::Backends::Memory::Client::Channel
#extra_response_headers_lookup MessageBus::Implementation
#get_message MessageBus::Backends::Postgres
#get_message MessageBus::Backends::Memory
#get_message MessageBus::Backends::Redis
#get_message MessageBus::Backends::Base
#get_value MessageBus::Backends::Postgres::Client
#get_value MessageBus::Backends::Memory::Client
#global_backlog MessageBus::Backends::Base
#global_backlog MessageBus::Backends::Memory::Client
#global_backlog MessageBus::Backends::Redis
#global_backlog MessageBus::Backends::Postgres::Client
#global_backlog MessageBus::Implementation
#global_backlog MessageBus::Backends::Memory
#global_backlog MessageBus::Backends::Postgres
#global_id MessageBus::Message
#global_subscribe MessageBus::Backends::Postgres
#global_subscribe MessageBus::Backends::Redis
#global_subscribe MessageBus::Backends::Base
#global_subscribe MessageBus::Backends::Memory
#global_unsubscribe MessageBus::Backends::Postgres
#global_unsubscribe MessageBus::Backends::Base
#global_unsubscribe MessageBus::Backends::Redis
#global_unsubscribe MessageBus::Backends::Memory
#group_ids MessageBus::Message
#group_ids MessageBus::Client
#group_ids_lookup MessageBus::Implementation
#hash MessageBus::DistributedCache
#headers MessageBus::Client
#headers Thin::AsyncResponse
#highest_id MessageBus::Backends::Redis::BackLogOutOfOrder
#identity MessageBus::DistributedCache
#initialize MessageBus::HTTPClient
#initialize MessageBus::ConnectionManager
#initialize MessageBus::Codec::Oj
#initialize MessageBus::Client
#initialize MessageBus::Backends::Memory::Client::Channel
#initialize MessageBus::Backends::Postgres
#initialize MessageBus::Backends::Postgres::Client
#initialize MessageBus::HTTPClient::Channel
#initialize MessageBus::DistributedCache
#initialize MessageBus::Backends::Memory::Client
#initialize MessageBus::Implementation
#initialize Thin::DeferrableBody
#initialize MessageBus::Backends::Base
#initialize MessageBus::TimerThread
#initialize MessageBus::Rack::Middleware
#initialize MessageBus::Backends::Memory
#initialize MessageBus::TimerThread::Cancelable
#initialize MessageBus::DistributedCache::Manager
#initialize MessageBus::Backends::Redis::BackLogOutOfOrder
#initialize MessageBus::Backends::Redis
#initialize Thin::AsyncResponse
#io MessageBus::Client
#is_admin_lookup MessageBus::Implementation
#jobs MessageBus::TimerThread
#keepalive_interval MessageBus::Implementation
#keepalive_interval= MessageBus::Implementation
#key MessageBus::DistributedCache
#last_id MessageBus::Implementation
#last_id MessageBus::Backends::Postgres
#last_id MessageBus::Backends::Redis
#last_id MessageBus::Backends::Base
#last_id MessageBus::Backends::Memory
#last_ids MessageBus::Implementation
#last_ids MessageBus::Backends::Base
#last_ids MessageBus::Backends::Redis
#last_ids MessageBus::Backends::Memory
#last_ids MessageBus::Backends::Postgres
#last_message MessageBus::Implementation
#last_message_id MessageBus::HTTPClient::Channel
#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::Backends::Memory::Client
#max_backlog_age MessageBus::Backends::Base
#max_backlog_age= MessageBus::Backends::Memory
#max_backlog_size MessageBus::Backends::Base
#max_global_backlog_size MessageBus::Backends::Base
#max_id MessageBus::Backends::Postgres::Client
#max_id MessageBus::Backends::Memory::Client
#max_ids MessageBus::Backends::Postgres::Client
#max_in_memory_publish_backlog MessageBus::Backends::Base
#max_poll_interval MessageBus::HTTPClient
#message MessageBus::Backends::Memory::Client::Listener
#message MessageBus::Backends::Postgres::Client::Listener
#message_id MessageBus::Message
#min_poll_interval MessageBus::HTTPClient
#notify_clients MessageBus::ConnectionManager
#off MessageBus::Implementation
#off? MessageBus::Implementation
#on MessageBus::Implementation
#on_connect MessageBus::Implementation
#on_disconnect MessageBus::Implementation
#on_error MessageBus::TimerThread
#on_middleware_error MessageBus::Implementation
#process_message MessageBus::DistributedCache::Manager
#publish MessageBus::Backends::Redis
#publish MessageBus::Backends::Base
#publish MessageBus::Backends::Postgres
#publish MessageBus::Backends::Postgres::Client
#publish MessageBus::Implementation
#publish MessageBus::DistributedCache::Manager
#publish MessageBus::Backends::Memory
#queue MessageBus::TimerThread
#rack_hijack_enabled= MessageBus::Implementation
#rack_hijack_enabled? MessageBus::Implementation
#redis_config= MessageBus::Implementation
#register MessageBus::DistributedCache::Manager
#register_client_message_filter MessageBus::Implementation
#reliable_pub_sub MessageBus::Implementation
#reliable_pub_sub= MessageBus::Implementation
#remove_client MessageBus::ConnectionManager
#reset! MessageBus::Backends::Redis
#reset! MessageBus::Backends::Base
#reset! MessageBus::Backends::Memory::Client
#reset! MessageBus::Backends::Postgres::Client
#reset! MessageBus::Implementation
#reset! MessageBus::Backends::Postgres
reset! MessageBus::Backends::Postgres
#reset! MessageBus::Backends::Memory
#send_headers Thin::AsyncResponse
#seq MessageBus::Client
#set MessageBus::DistributedCache::Manager
#site_id MessageBus::Message
#site_id MessageBus::Client
#site_id_lookup MessageBus::Implementation
#skip_middleware? MessageBus::Rails::Railtie
#start MessageBus::HTTPClient
#started_listener MessageBus::Rack::Middleware
#stats MessageBus::HTTPClient
#status Thin::AsyncResponse
#status MessageBus::HTTPClient
#stop MessageBus::TimerThread
#stop MessageBus::HTTPClient
#stop_listener MessageBus::Rack::Middleware
#subscribe MessageBus::Backends::Redis
#subscribe MessageBus::Backends::Base
#subscribe MessageBus::HTTPClient
#subscribe MessageBus::Backends::Memory::Client::Listener
#subscribe MessageBus::Client
#subscribe MessageBus::Implementation
#subscribe MessageBus::Backends::Postgres::Client
#subscribe MessageBus::Backends::Postgres::Client::Listener
#subscribe MessageBus::Backends::Memory
#subscribe MessageBus::Backends::Memory::Client
#subscribe MessageBus::Backends::Postgres
#subscribed MessageBus::Backends::Base
#subscribers MessageBus::DistributedCache::Manager
#subscriptions MessageBus::Client
#synchronize MessageBus::Client
#timer MessageBus::Implementation
#transport_codec MessageBus::Implementation
#transport_codec= MessageBus::Implementation
#ttl MessageBus::Backends::Memory::Client::Channel
#unsubscribe MessageBus::HTTPClient
#unsubscribe MessageBus::Implementation
#unsubscribe MessageBus::Backends::Postgres::Client
#unsubscribe MessageBus::Backends::Postgres::Client::Listener
#unsubscribe MessageBus::Backends::Memory::Client
#unsubscribe MessageBus::Backends::Memory::Client::Listener
#use_chunked MessageBus::Client
#user_id MessageBus::Client
#user_id_lookup MessageBus::Implementation
#user_ids MessageBus::Message
#write Thin::AsyncResponse