Method List

Classes Methods Files

Search:

#ack! PikaQue::Worker
#add PikaQue::Middleware::Chain
#add_processor PikaQue::Runner
backoff_periods PikaQue::Handlers::RetryHandler
#bind_queue PikaQue::Handlers::RetryHandler
#bind_queue PikaQue::Handlers::DelayHandler
#bind_queue PikaQue::Handlers::DLXRetryHandler
#bind_queue PikaQue::Handlers::DefaultHandler
#bind_queue PikaQue::Handlers::ErrorHandler
#broker PikaQue::DelayWorker
#broker PikaQue::Subscriber
#call PikaQue::Middleware::ActiveRecord
#call PikaQue::Middleware::RequestStore
#call PikaQue::Logging::PikaQueFormatter
#channel PikaQue::Broker
#cleanup PikaQue::Broker
#clear PikaQue::Middleware::Chain
#close PikaQue::Handlers::DefaultHandler
#close PikaQue::Handlers::DLXRetryHandler
#close PikaQue::Handlers::RetryHandler
#close PikaQue::Handlers::ErrorHandler
#close PikaQue::Handlers::DelayHandler
#config PikaQue::Runner
#config PikaQue::Worker::ClassMethods
#config PikaQue::CLI
config PikaQue
configure PikaQue
#connect! PikaQue::Connection
#connected? PikaQue::Connection
#connection PikaQue::Connection
connection PikaQue
#constantize PikaQue::Util
#consumer_arguments PikaQue::Worker
#content_type PikaQue::Codecs::NOOP
#content_type PikaQue::Codecs::RAILS
#content_type PikaQue::Codecs::JSON
create PikaQue::Connection
#daemonize PikaQue::CLI
#decode PikaQue::Codecs::RAILS
#decode PikaQue::Codecs::NOOP
#decode PikaQue::Codecs::JSON
#deep_merge PikaQue::Configuration
#default_handler PikaQue::Broker
#disconnect! PikaQue::Connection
#each PikaQue::Middleware::Chain
#encode PikaQue::Codecs::RAILS
#encode PikaQue::Codecs::JSON
#encode PikaQue::Codecs::NOOP
#enqueue ActiveJob::QueueAdapters::PikaQueRails5
#enqueue PikaQue::Worker::ClassMethods
enqueue ActiveJob::QueueAdapters::PikaQueRails4
#enqueue_at ActiveJob::QueueAdapters::PikaQueRails5
enqueue_at ActiveJob::QueueAdapters::PikaQueRails4
#enqueue_at PikaQue::Worker::ClassMethods
#ensure_connection PikaQue::Connection
#entries PikaQue::Middleware::Chain
#environment PikaQue::CLI
#exchange PikaQue::Broker
#exchange_name PikaQue::Publisher
#exists? PikaQue::Middleware::Chain
#from_queue PikaQue::Worker::ClassMethods
#handle PikaQue::Handlers::DLXRetryHandler
#handle PikaQue::Handlers::ErrorHandler
#handle PikaQue::Handlers::DefaultHandler
#handle PikaQue::Handlers::DelayHandler
#handle PikaQue::Handlers::RetryHandler
#handle_message PikaQue::Subscriber
#handle_with PikaQue::Worker::ClassMethods
#handler PikaQue::Subscriber
#handler PikaQue::Broker
#handler PikaQue::DelayWorker
#handler_class PikaQue::Worker::ClassMethods
#handler_opts PikaQue::Worker::ClassMethods
included PikaQue::Worker
#increment PikaQue::Metrics::NullMetric
#increment PikaQue::Metrics::LogMetric
#inflector PikaQue::Util
#init_channel PikaQue::Broker
#init_config PikaQue::CLI
init_logger PikaQue::Logging
#init_logger PikaQue::CLI
init_metrics PikaQue::Metrics
#initialize PikaQue::Worker
#initialize PikaQue::Subscriber
#initialize PikaQue::Handlers::DefaultHandler
#initialize PikaQue::DelayWorker
#initialize PikaQue::Handlers::RetryHandler
#initialize PikaQue::Broker
#initialize PikaQue::Handlers::DLXRetryHandler
#initialize PikaQue::Handlers::DelayHandler
#initialize PikaQue::Middleware::Chain
#initialize PikaQue::Configuration
#initialize PikaQue::Connection
#initialize PikaQue::Publisher
#initialize PikaQue::Launcher
#initialize ActiveJob::QueueAdapters::PikaQueRails5
#initialize PikaQue::Processor
#initialize PikaQue::Middleware::Entry
#initialize PikaQue::Handlers::ErrorHandler
#initialize_copy PikaQue::Middleware::Chain
#insert_after PikaQue::Middleware::Chain
#insert_before PikaQue::Middleware::Chain
#invoke PikaQue::Middleware::Chain
#klass PikaQue::Middleware::Entry
#launch PikaQue::Launcher
launch PikaQue::Launcher
#load PikaQue::Configuration
#load_app PikaQue::CLI
#local_config PikaQue::Worker::ClassMethods
#local_connection? PikaQue::Broker
#logger PikaQue::Logging
#logger PikaQue::Worker
#logger PikaQue::DelayWorker
logger PikaQue::Logging
logger PikaQue
logger= PikaQue::Logging
logger= PikaQue
#make_new PikaQue::Middleware::Entry
#measure PikaQue::Metrics::NullMetric
#measure PikaQue::Metrics::LogMetric
#merge PikaQue::Configuration
#merge! PikaQue::Configuration
metrics PikaQue::Metrics
#metrics PikaQue::Metrics
middleware PikaQue
next_ttl PikaQue::Handlers::RetryHandler
#notify_reporters PikaQue::Reporters
#parse PikaQue::CLI
#parse_options PikaQue::CLI
#perform PikaQue::RailsWorker
#pool PikaQue::Subscriber
#pool PikaQue::DelayWorker
#prepare PikaQue::Worker
#prepare PikaQue::DelayWorker
#prepare_server PikaQue::CLI
#prepend PikaQue::Middleware::Chain
#priority PikaQue::Worker::ClassMethods
#process PikaQue::Processor
#processor PikaQue::Runner
#processors PikaQue::Runner
#publish PikaQue::Publisher
#queue PikaQue::Subscriber
#queue PikaQue::Broker
#queue PikaQue::DelayWorker
#queue_name PikaQue::Worker::ClassMethods
#queue_opts PikaQue::Worker::ClassMethods
#register_worker_class PikaQue::Util
#reject! PikaQue::Worker
#remove PikaQue::Middleware::Chain
#report PikaQue::Reporters::LogReporter
reporters PikaQue
#requeue! PikaQue::Worker
reset! PikaQue
#retrieve PikaQue::Middleware::Chain
#run PikaQue::Worker
#run PikaQue::Runner
#run PikaQue::CLI
#run PikaQue::DelayWorker
#setup PikaQue::Processor
#setup_handler PikaQue::Subscriber
#setup_processors PikaQue::Runner
#setup_queue PikaQue::Subscriber
#start PikaQue::Processor
#start PikaQue::Worker
#start PikaQue::Broker
#start PikaQue::DelayWorker
#stop PikaQue::DelayWorker
#stop PikaQue::Processor
#stop PikaQue::Worker
#stop PikaQue::Runner
#stop PikaQue::Broker
#subscribe PikaQue::Subscriber
#teardown PikaQue::Subscriber
#unsubscribe PikaQue::Subscriber
#work PikaQue::Worker
#work PikaQue::DelayWorker
#worker_classes PikaQue::Util
#write_pid PikaQue::CLI