Table of Contents - active_publisher-1.3.0 Documentation
Classes and Modules
- ActivePublisher
- ActivePublisher::Async
- ActivePublisher::Async::InMemoryAdapter
- ActivePublisher::Async::InMemoryAdapter::Adapter
- ActivePublisher::Async::InMemoryAdapter::AsyncQueue
- ActivePublisher::Async::InMemoryAdapter::Channel
- ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- ActivePublisher::Async::InMemoryAdapter::UnableToPersistMessageError
- ActivePublisher::Async::RedisAdapter
- ActivePublisher::Async::RedisAdapter::Adapter
- ActivePublisher::Async::RedisAdapter::Consumer
- ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- ActivePublisher::Configuration
- ActivePublisher::Connection
- ActivePublisher::ExchangeMismatchError
- ActivePublisher::FailedPublisherConfirms
- ActivePublisher::Logging
- ActivePublisher::Message
- ActivePublisher::UnknownMessageClassError
Methods
- ::attempt_to_load_yaml_file — ActivePublisher::Configuration
- ::configuration — ActivePublisher
- ::configure — ActivePublisher
- ::configure_from_yaml_and_cli — ActivePublisher::Configuration
- ::connected? — ActivePublisher::Connection
- ::connection — ActivePublisher::Connection
- ::connection_options — ActivePublisher::Connection
- ::create_connection — ActivePublisher::Connection
- ::disconnect! — ActivePublisher::Connection
- ::fetch_config_value — ActivePublisher::Configuration
- ::initialize_logger — ActivePublisher::Logging
- ::logger — ActivePublisher::Logging
- ::logger= — ActivePublisher::Logging
- ::new — ActivePublisher::Async::InMemoryAdapter::Adapter
- ::new — ActivePublisher::Async::InMemoryAdapter::AsyncQueue
- ::new — ActivePublisher::Async::InMemoryAdapter::Channel
- ::new — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- ::new — ActivePublisher::Async::RedisAdapter::Adapter
- ::new — ActivePublisher::Async::RedisAdapter::Consumer
- ::new — ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- ::new — ActivePublisher::Configuration
- ::new — ActivePublisher::Async::InMemoryAdapter
- ::new — ActivePublisher::Async::RedisAdapter
- ::on_blocked — ActivePublisher::Connection
- ::on_unblocked — ActivePublisher::Connection
- ::publish — ActivePublisher
- ::publish_all — ActivePublisher
- ::publish_async — ActivePublisher
- ::publishing_options — ActivePublisher
- ::with_exchange — ActivePublisher
- #<< — ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- #alive? — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #await_network_reconnect — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #back_pressure_strategy= — ActivePublisher::Async::InMemoryAdapter::AsyncQueue
- #cleanup_up_channel — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #close — ActivePublisher::Async::InMemoryAdapter::Channel
- #concat — ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- #confirm_select — ActivePublisher::Async::InMemoryAdapter::Channel
- #connection_string= — ActivePublisher::Configuration
- #consumer_sampled_queue_size — ActivePublisher::Async::InMemoryAdapter::AsyncQueue
- #create_and_supervise_consumers! — ActivePublisher::Async::InMemoryAdapter::AsyncQueue
- #create_and_supervise_consumers! — ActivePublisher::Async::RedisAdapter::Consumer
- #empty? — ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- #flush_queue! — ActivePublisher::Async::RedisAdapter::Adapter
- #handle_current_messages_on_unknown_error — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #kill — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #logger — ActivePublisher::Logging
- #make_channel — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #pop_up_to — ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- #publish — ActivePublisher::Async::InMemoryAdapter::Adapter
- #publish — ActivePublisher::Async::RedisAdapter::Adapter
- #publish_all — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #push — ActivePublisher::Async::InMemoryAdapter::AsyncQueue
- #shift — ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- #shutdown! — ActivePublisher::Async::InMemoryAdapter::Adapter
- #shutdown! — ActivePublisher::Async::RedisAdapter::Adapter
- #size — ActivePublisher::Async::InMemoryAdapter::AsyncQueue
- #size — ActivePublisher::Async::RedisAdapter::Consumer
- #size — ActivePublisher::Async::RedisAdapter::RedisMultiPopQueue
- #start_consuming_thread — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #start_thread — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #topic — ActivePublisher::Async::InMemoryAdapter::Channel
- #update_last_tick_at — ActivePublisher::Async::InMemoryAdapter::ConsumerThread
- #using_publisher_confirms? — ActivePublisher::Async::InMemoryAdapter::Channel
- #wait_for_confirms — ActivePublisher::Async::InMemoryAdapter::Channel
- #wait_for_confirms — ActivePublisher::Async::InMemoryAdapter::ConsumerThread