Module: MessageBus

Extended by:: Implementation

Defined in:: lib/message_bus.rb,
lib/message_bus.rb,
lib/message_bus/version.rb,
lib/message_bus/backends.rb,
lib/message_bus/codec/oj.rb,
lib/message_bus/codec/base.rb,
lib/message_bus/codec/json.rb,
lib/message_bus/http_client.rb,
lib/message_bus/backends/base.rb,
lib/message_bus/rails/railtie.rb,
lib/message_bus/backends/redis.rb,
lib/message_bus/backends/memory.rb,
lib/message_bus/backends/postgres.rb,
lib/message_bus/distributed_cache.rb,
lib/message_bus/http_client/channel.rb,
lib/message_bus/http_client/version.rb

Overview

See Also:

Implementation

Defined Under Namespace

Modules: Backends, Codec, Implementation, Rack, Rails Classes: BusDestroyed, Client, ConnectionManager, DistributedCache, HTTPClient, Instance, InvalidMessage, InvalidMessageTarget, Message, TimerThread

Constant Summary collapse

BACKENDS =

{}

VERSION =

"4.3.8"

Instance Attribute Summary

Attributes included from Implementation

Method Summary

Methods included from Implementation

after_fork, allow_broadcast=, allow_broadcast?, backend, backend_instance, backend_instance=, backlog, base_route, base_route=, blocking_subscribe, chunked_encoding_enabled=, chunked_encoding_enabled?, client_message_filters, configure, destroy, extra_response_headers_lookup, global_backlog, group_ids_lookup, initialize, is_admin_lookup, keepalive_interval, keepalive_interval=, last_id, last_ids, last_message, listening?, local_subscribe, local_unsubscribe, logger, logger=, long_polling_enabled=, long_polling_enabled?, long_polling_interval, long_polling_interval=, max_active_clients, max_active_clients=, off, off?, on, on_connect, on_disconnect, on_middleware_error, publish, rack_hijack_enabled=, rack_hijack_enabled?, redis_config=, register_client_message_filter, reliable_pub_sub, reliable_pub_sub=, reset!, site_id_lookup, subscribe, timer, transport_codec, transport_codec=, unsubscribe, user_id_lookup