Table of Contents - pika_que-0.2.0 Documentation
Classes and Modules
- ActiveJob
- ActiveJob::QueueAdapters
- ActiveJob::QueueAdapters::PikaQueRails4
- ActiveJob::QueueAdapters::PikaQueRails5
- PikaQue
- PikaQue::Broker
- PikaQue::CLI
- PikaQue::Codecs
- PikaQue::Codecs::JSON
- PikaQue::Codecs::NOOP
- PikaQue::Codecs::RAILS
- PikaQue::Configuration
- PikaQue::Connection
- PikaQue::DelayWorker
- PikaQue::Handlers
- PikaQue::Handlers::DLXRetryHandler
- PikaQue::Handlers::DefaultHandler
- PikaQue::Handlers::DelayHandler
- PikaQue::Handlers::ErrorHandler
- PikaQue::Handlers::RetryHandler
- PikaQue::Launcher
- PikaQue::Logging
- PikaQue::Logging::PikaQueFormatter
- PikaQue::Metrics
- PikaQue::Metrics::LogMetric
- PikaQue::Metrics::NullMetric
- PikaQue::Middleware
- PikaQue::Middleware::ActiveRecord
- PikaQue::Middleware::Chain
- PikaQue::Middleware::Entry
- PikaQue::Processor
- PikaQue::Publisher
- PikaQue::Rails
- PikaQue::RailsWorker
- PikaQue::Reporters
- PikaQue::Reporters::LogReporter
- PikaQue::Runner
- PikaQue::SetupError
- PikaQue::Subscriber
- PikaQue::Util
- PikaQue::Worker
- PikaQue::Worker::ClassMethods
Methods
- ::backoff_periods — PikaQue::Handlers::RetryHandler
- ::config — PikaQue
- ::configure — PikaQue
- ::connection — PikaQue
- ::create — PikaQue::Connection
- ::included — PikaQue::Worker
- ::init_logger — PikaQue::Logging
- ::init_metrics — PikaQue::Metrics
- ::launch — PikaQue::Launcher
- ::logger — PikaQue
- ::logger — PikaQue::Logging
- ::logger= — PikaQue
- ::logger= — PikaQue::Logging
- ::metrics — PikaQue::Metrics
- ::middleware — PikaQue
- ::new — ActiveJob::QueueAdapters::PikaQueRails5
- ::new — PikaQue::Broker
- ::new — PikaQue::Configuration
- ::new — PikaQue::Connection
- ::new — PikaQue::DelayWorker
- ::new — PikaQue::Handlers::DefaultHandler
- ::new — PikaQue::Handlers::DelayHandler
- ::new — PikaQue::Handlers::DLXRetryHandler
- ::new — PikaQue::Handlers::ErrorHandler
- ::new — PikaQue::Handlers::RetryHandler
- ::new — PikaQue::Launcher
- ::new — PikaQue::Middleware::Chain
- ::new — PikaQue::Middleware::Entry
- ::new — PikaQue::Processor
- ::new — PikaQue::Publisher
- ::new — PikaQue::Subscriber
- ::new — PikaQue::Worker
- ::next_ttl — PikaQue::Handlers::RetryHandler
- ::reporters — PikaQue
- ::reset! — PikaQue
- #ack! — PikaQue::Worker
- #add — PikaQue::Middleware::Chain
- #add_processor — PikaQue::Runner
- #bind_queue — PikaQue::Handlers::DefaultHandler
- #bind_queue — PikaQue::Handlers::DelayHandler
- #bind_queue — PikaQue::Handlers::DLXRetryHandler
- #bind_queue — PikaQue::Handlers::ErrorHandler
- #bind_queue — PikaQue::Handlers::RetryHandler
- #call — PikaQue::Logging::PikaQueFormatter
- #call — PikaQue::Middleware::ActiveRecord
- #channel — PikaQue::Broker
- #cleanup — PikaQue::Broker
- #clear — PikaQue::Middleware::Chain
- #close — PikaQue::Handlers::DefaultHandler
- #close — PikaQue::Handlers::DelayHandler
- #close — PikaQue::Handlers::DLXRetryHandler
- #close — PikaQue::Handlers::ErrorHandler
- #close — PikaQue::Handlers::RetryHandler
- #config — PikaQue::CLI
- #config — PikaQue::Runner
- #config — PikaQue::Worker::ClassMethods
- #connect! — PikaQue::Connection
- #connected? — PikaQue::Connection
- #constantize — PikaQue::Util
- #consumer_arguments — PikaQue::Worker
- #content_type — PikaQue::Codecs::JSON
- #content_type — PikaQue::Codecs::NOOP
- #content_type — PikaQue::Codecs::RAILS
- #daemonize — PikaQue::CLI
- #decode — PikaQue::Codecs::JSON
- #decode — PikaQue::Codecs::NOOP
- #decode — PikaQue::Codecs::RAILS
- #deep_merge — PikaQue::Configuration
- #default_handler — PikaQue::Broker
- #disconnect! — PikaQue::Connection
- #each — PikaQue::Middleware::Chain
- #encode — PikaQue::Codecs::JSON
- #encode — PikaQue::Codecs::NOOP
- #encode — PikaQue::Codecs::RAILS
- #enqueue — PikaQue::Worker::ClassMethods
- #enqueue_at — PikaQue::Worker::ClassMethods
- #ensure_connection — PikaQue::Connection
- #exchange — PikaQue::Broker
- #exchange_durable? — PikaQue::Handlers::DelayHandler
- #exchange_durable? — PikaQue::Handlers::DLXRetryHandler
- #exchange_durable? — PikaQue::Handlers::ErrorHandler
- #exchange_durable? — PikaQue::Handlers::RetryHandler
- #exchange_name — PikaQue::Publisher
- #exists? — PikaQue::Middleware::Chain
- #failure_count — PikaQue::Handlers::DLXRetryHandler
- #failure_count — PikaQue::Handlers::RetryHandler
- #from_queue — PikaQue::Worker::ClassMethods
- #handle — PikaQue::Handlers::DefaultHandler
- #handle — PikaQue::Handlers::DelayHandler
- #handle — PikaQue::Handlers::DLXRetryHandler
- #handle — PikaQue::Handlers::ErrorHandler
- #handle — PikaQue::Handlers::RetryHandler
- #handle_message — PikaQue::Subscriber
- #handle_retry — PikaQue::Handlers::DLXRetryHandler
- #handle_retry — PikaQue::Handlers::RetryHandler
- #handle_signal — PikaQue::Launcher
- #handle_with — PikaQue::Worker::ClassMethods
- #handler — PikaQue::Broker
- #increment — PikaQue::Metrics::LogMetric
- #increment — PikaQue::Metrics::NullMetric
- #inflector — PikaQue::Util
- #init_channel — PikaQue::Broker
- #init_config — PikaQue::CLI
- #init_logger — PikaQue::CLI
- #initialize_copy — PikaQue::Middleware::Chain
- #insert_after — PikaQue::Middleware::Chain
- #insert_before — PikaQue::Middleware::Chain
- #invoke — PikaQue::Middleware::Chain
- #launch — PikaQue::Launcher
- #load — PikaQue::Configuration
- #load_app — PikaQue::CLI
- #local_connection? — PikaQue::Broker
- #log_thread_backtraces — PikaQue::Launcher
- #logger — PikaQue::DelayWorker
- #logger — PikaQue::Logging
- #logger — PikaQue::Worker
- #make_new — PikaQue::Middleware::Entry
- #measure — PikaQue::Metrics::LogMetric
- #measure — PikaQue::Metrics::NullMetric
- #merge — PikaQue::Configuration
- #merge! — PikaQue::Configuration
- #metrics — PikaQue::Metrics
- #next_delay_period — PikaQue::Handlers::DelayHandler
- #notify_reporters — PikaQue::Reporters
- #parse — PikaQue::CLI
- #parse_options — PikaQue::CLI
- #perform — PikaQue::RailsWorker
- #perform_async — PikaQue::Worker::ClassMethods
- #perform_at — PikaQue::Worker::ClassMethods
- #prepare — PikaQue::DelayWorker
- #prepare — PikaQue::Worker
- #prepare_server — PikaQue::CLI
- #prepend — PikaQue::Middleware::Chain
- #process — PikaQue::Processor
- #processor — PikaQue::Runner
- #processors — PikaQue::Runner
- #publish — PikaQue::Handlers::ErrorHandler
- #publish — PikaQue::Publisher
- #publish_delay — PikaQue::Handlers::DelayHandler
- #publish_error — PikaQue::Handlers::DLXRetryHandler
- #publish_error — PikaQue::Handlers::RetryHandler
- #publish_retry — PikaQue::Handlers::RetryHandler
- #publish_work — PikaQue::Handlers::DelayHandler
- #publisher — PikaQue::Worker::ClassMethods
- #queue — PikaQue::Broker
- #queue_durable? — PikaQue::Handlers::DelayHandler
- #queue_durable? — PikaQue::Handlers::DLXRetryHandler
- #queue_durable? — PikaQue::Handlers::ErrorHandler
- #queue_durable? — PikaQue::Handlers::RetryHandler
- #register_signals — PikaQue::Launcher
- #register_worker_class — PikaQue::Util
- #reject! — PikaQue::Worker
- #remove — PikaQue::Middleware::Chain
- #report — PikaQue::Reporters::LogReporter
- #requeue! — PikaQue::Worker
- #retrieve — PikaQue::Middleware::Chain
- #run — PikaQue::CLI
- #run — PikaQue::DelayWorker
- #run — PikaQue::Runner
- #run — PikaQue::Worker
- #setup — PikaQue::Processor
- #setup_exchanges — PikaQue::Handlers::DelayHandler
- #setup_exchanges — PikaQue::Handlers::DLXRetryHandler
- #setup_exchanges — PikaQue::Handlers::RetryHandler
- #setup_handler — PikaQue::Subscriber
- #setup_processors — PikaQue::Runner
- #setup_queue — PikaQue::Subscriber
- #setup_queues — PikaQue::Handlers::DelayHandler
- #setup_queues — PikaQue::Handlers::DLXRetryHandler
- #setup_queues — PikaQue::Handlers::RetryHandler
- #start — PikaQue::Broker
- #start — PikaQue::DelayWorker
- #start — PikaQue::Processor
- #start — PikaQue::Worker
- #stop — PikaQue::Broker
- #stop — PikaQue::DelayWorker
- #stop — PikaQue::Processor
- #stop — PikaQue::Runner
- #stop — PikaQue::Worker
- #subscribe — PikaQue::Subscriber
- #teardown — PikaQue::Subscriber
- #unsubscribe — PikaQue::Subscriber
- #wait_for_signal — PikaQue::Launcher
- #work — PikaQue::DelayWorker
- #work — PikaQue::Worker
- #worker_classes — PikaQue::Util
- #write_pid — PikaQue::CLI