Method List

Classes Methods Files

Search:

#[] Lepus::Message::Metadata
[] Lepus::Testing::Exchange
#[] Lepus::Message::DeliveryInfo
[] Lepus::Consumers::WorkerFactory
abstract_class= Lepus::Consumer
abstract_class= Lepus::Producer
abstract_class? Lepus::Consumer
abstract_class? Lepus::Producer
add Lepus::ProcessRegistry
#add Lepus::ProcessRegistry::Backend
#add Lepus::ProcessRegistry::FileBackend
#add Lepus::ProcessRegistry::RabbitmqBackend
#add_message Lepus::Testing::Exchange
#after_boot Lepus::Processes::Callbacks::ClassMethods
#after_fork Lepus::Consumers::Worker
#after_fork Lepus::Consumers::WorkerFactory
#after_shutdown Lepus::Processes::Callbacks::ClassMethods
aggregator Lepus::Web
all Lepus::ProcessRegistry
all Lepus::Testing::Exchange
#all Lepus::Consumers::StatsRegistry
#all Lepus::ProcessRegistry::Backend
#all Lepus::ProcessRegistry::FileBackend
#all Lepus::ProcessRegistry::RabbitmqBackend
#all_processes Lepus::Web::Aggregator
#app_executor Lepus::Configuration
#application_name Lepus::Configuration
assets_path Lepus::Web
#assign Lepus::Producers::Config
#assign Lepus::Consumers::WorkerFactory
#attributes Lepus::Process
#available? Lepus::ConnectionPool
#available_count Lepus::ConnectionPool
backend Lepus::ProcessRegistry
base_path Lepus::Web
#base_url Lepus::Web::ManagementAPI
#before_boot Lepus::Processes::Callbacks::ClassMethods
#before_fork Lepus::Consumers::Worker
#before_fork Lepus::Consumers::WorkerFactory
#before_shutdown Lepus::Processes::Callbacks::ClassMethods
#binds_args Lepus::Consumers::Config
build Lepus::Web::App
#build Lepus::Testing::MessageBuilder
#build_deregister Lepus::ProcessRegistry::MessageBuilder
#build_heartbeat Lepus::ProcessRegistry::MessageBuilder
#build_management_api Lepus::Configuration
#build_process_registry_backend Lepus::Configuration
#call Lepus::Web::API
#call Lepus::Middleware
#call Lepus::Consumers::Middlewares::JSON
#call Lepus::Producers::Middlewares::JSON
#call Lepus::Consumers::Middlewares::Unique
#call Lepus::Producers::Middlewares::Header
#call Lepus::Producers::Middlewares::Unique
#call Lepus::Consumers::Middlewares::MaxRetry
#call Lepus::Consumers::Middlewares::Honeybadger
#call Lepus::Producers::Middlewares::CorrelationId
#call Lepus::Producers::Middlewares::Instrumentation
#call Lepus::Consumers::Middlewares::ExceptionLogger
call Lepus::Web
#channel Lepus::Message
#channel_args Lepus::Consumers::Config
#channel_publish Lepus::Publisher
#checkin Lepus::ConnectionPool
#checkout Lepus::ConnectionPool
#classify Lepus::Primitive::String
#clear Lepus::Web::Aggregator
clear Lepus::ProcessRegistry
#clear Lepus::ProcessRegistry::Backend
#clear Lepus::ProcessRegistry::FileBackend
#clear Lepus::ProcessRegistry::RabbitmqBackend
clear_all! Lepus::Testing::Exchange
clear_all_messages! Lepus::Testing
clear_all_messages! Lepus::Testing::Exchange
#clear_hooks Lepus::Supervisor::LifecycleHooks::ClassMethods
#clear_messages Lepus::Testing::Exchange
client Lepus::Prometheus
coerce Lepus::Message
coerce Lepus::Process
#collect Lepus::Prometheus::Collector
combine Lepus::MiddlewareChain
config Lepus
config Lepus::Consumer
configure Lepus
configure Lepus::Consumer
configure Lepus::Producer
#conn_suffix Lepus::ConnectionPool
#connection_count Lepus::Consumers::StatsRegistry
#connection_name Lepus::Configuration
#connections Lepus::Web::ManagementAPI
#constantize Lepus::Primitive::String
consumer_capture_errors! Lepus::Testing
#consumer_class Lepus::Message
#consumer_class Lepus::Consumers::Stats
#consumer_middleware_chain Lepus::Configuration
#consumer_middlewares Lepus::Configuration
consumer_perform Lepus::Testing
#consumer_queue_args Lepus::Consumers::Config
consumer_raise_errors! Lepus::Testing
consumer_raise_errors? Lepus::Testing
#consumers Lepus::Consumers::WorkerFactory
#consumers_directory Lepus::Configuration
#count Lepus::Web::Aggregator
count Lepus::ProcessRegistry
#count Lepus::ProcessRegistry::Backend
#count Lepus::ProcessRegistry::FileBackend
#count Lepus::ProcessRegistry::RabbitmqBackend
#create_connection Lepus::Configuration
#deep_symbolize_keys Lepus::Primitive::Hash
default Lepus::Consumers::WorkerFactory
#definer Lepus::Consumers::Worker
definition Lepus::Producer
#definition Lepus::Producer
delete Lepus::ProcessRegistry
#delete Lepus::Supervisor::Pidfile
#delete Lepus::ProcessRegistry::Backend
#delete Lepus::ProcessRegistry::FileBackend
#delete Lepus::ProcessRegistry::RabbitmqBackend
#delivery_info Lepus::Message
#deregister Lepus::Process
#deregister_process Lepus::LogSubscriber
descendants Lepus::Consumer
descendants Lepus::Producer
#description Lepus::Testing::RSpecMatchers::PublishLepusMessage
#description Lepus::Testing::RSpecMatchers::ProcessLepusMessage
#destroy! Lepus::Process
disable! Lepus::Testing
#disable! Lepus::Producers::Hooks
#disabled? Lepus::Producers::Hooks
eager_load_consumers! Lepus
emit Lepus::Prometheus
#empty? Lepus::MiddlewareChain
#empty? Lepus::Testing::Exchange
enable! Lepus::Testing
#enable! Lepus::Producers::Hooks
#enabled? Lepus::Producers::Hooks
ensure_started Lepus::Web
#eql? Lepus::Message
#eql? Lepus::Process
#eql? Lepus::Message::Metadata
#eql? Lepus::Message::DeliveryInfo
#error_queue_args Lepus::Consumers::Config
#error_queue_name Lepus::Consumers::Config
#errored Lepus::Consumers::Stats
exchange Lepus::Testing
#exchange_enabled? Lepus::Producers::Hooks
#exchange_name Lepus::Consumers::Config
#exchange_name Lepus::Producers::Definition
#exchange_options Lepus::Consumers::Config
#exchange_options Lepus::Producers::Definition
exchanges Lepus::Testing
#exchanges Lepus::Web::ManagementAPI
#execute Lepus::MiddlewareChain
exists? Lepus::ProcessRegistry
exists? Lepus::Consumers::WorkerFactory
#exists? Lepus::ProcessRegistry::Backend
#exists? Lepus::ProcessRegistry::FileBackend
#exists? Lepus::ProcessRegistry::RabbitmqBackend
exit_on_failure? Lepus::CLI
#failure_message Lepus::Testing::RSpecMatchers::PublishLepusMessage
#failure_message Lepus::Testing::RSpecMatchers::ProcessLepusMessage
#failure_message_when_negated Lepus::Testing::RSpecMatchers::PublishLepusMessage
#failure_message_when_negated Lepus::Testing::RSpecMatchers::ProcessLepusMessage
fake_publisher! Lepus::Testing
fake_publisher_disable! Lepus::Testing
fake_publisher_enabled? Lepus::Testing
#fallback Lepus::ProcessRegistry::RabbitmqBackend
#find Lepus::Web::Aggregator
find Lepus::ProcessRegistry
#find Lepus::ProcessRegistry::Backend
#find Lepus::ProcessRegistry::FileBackend
#find Lepus::ProcessRegistry::RabbitmqBackend
#find_messages Lepus::Testing::Exchange
#for Lepus::Consumers::StatsRegistry
#freeze_with Lepus::Consumers::WorkerFactory
from_bunny Lepus::Message::Metadata
from_bunny Lepus::Message::DeliveryInfo
#graceful_termination Lepus::LogSubscriber
#handle_thread_error Lepus::AppExecutor
#heartbeat Lepus::Process
#heartbeat Lepus::Prometheus::Instrumentation::WorkerExtensions
#hostname Lepus::Processes::Base
#immediate_termination Lepus::LogSubscriber
immutate_with Lepus::Consumers::WorkerFactory
#in_use_count Lepus::ConnectionPool
included Lepus::Supervisor::Signals
included Lepus::Processes::Callbacks
included Lepus::Supervisor::Pidfiled
included Lepus::Processes::Supervised
included Lepus::Processes::Registrable
included Lepus::Supervisor::Maintenance
included Lepus::Supervisor::ChildrenPipes
included Lepus::Supervisor::LifecycleHooks
included Lepus::Supervisor::RegistryCleaner
inherited Lepus::Consumer
inherited Lepus::Producer
#inherited Lepus::Processes::Callbacks::ClassMethods
#initialize Lepus::InvalidConsumerReturnError
#initialize Lepus::Web::ConfigExtensions
#initialize Lepus::Message
#initialize Lepus::Process::NotFoundError
#initialize Lepus::Process
#initialize Lepus::Web::API
#initialize Lepus::Producer
#initialize Lepus::Publisher
#initialize Lepus::Middleware
#initialize Lepus::Supervisor
#initialize Lepus::Configuration
#initialize Lepus::Primitive::Hash
#initialize Lepus::Processes::Base
#initialize Lepus::Web::Aggregator
#initialize Lepus::ConnectionPool
#initialize Lepus::Consumers::Stats
#initialize Lepus::Consumers::Config
#initialize Lepus::Consumers::Worker
#initialize Lepus::Message::Metadata
#initialize Lepus::MiddlewareChain
#initialize Lepus::Producers::Config
#initialize Lepus::Testing::Exchange
#initialize Lepus::Consumers::Handler
#initialize Lepus::Processes::Runnable::InquiryMode
#initialize Lepus::Supervisor::Pidfile
#initialize Lepus::Web::ManagementAPI
#initialize Lepus::Producers::Definition
#initialize Lepus::Prometheus::Collector
#initialize Lepus::Message::DeliveryInfo
#initialize Lepus::Testing::RSpecMatchers::PublishLepusMessage
#initialize Lepus::Testing::RSpecMatchers::ProcessLepusMessage
#initialize Lepus::Testing::MessageBuilder
#initialize Lepus::Consumers::StatsRegistry
#initialize Lepus::Consumers::WorkerFactory
#initialize Lepus::Consumers::Middlewares::JSON
#initialize Lepus::Producers::Middlewares::JSON
#initialize Lepus::Consumers::Middlewares::Unique
#initialize Lepus::Producers::Middlewares::Header
#initialize Lepus::Producers::Middlewares::Unique
#initialize Lepus::ProcessRegistry::FileBackend
#initialize Lepus::Consumers::Middlewares::MaxRetry
#initialize Lepus::ProcessRegistry::MessageBuilder
#initialize Lepus::Consumers::Middlewares::Honeybadger
#initialize Lepus::ProcessRegistry::RabbitmqBackend
#initialize Lepus::Producers::Middlewares::CorrelationId
#initialize Lepus::Producers::Middlewares::Instrumentation
#initialize Lepus::Consumers::Middlewares::ExceptionLogger
install! Lepus::Prometheus::Instrumentation
#instantiate_process Lepus::Consumers::WorkerFactory
instrument Lepus
#interrupt Lepus::Processes::Interruptible
json Lepus::Web::RespondWith
#kind Lepus::Processes::Base
#last_delivery_errored? Lepus::Web::ConsumerExtensions
#last_delivery_errored? Lepus::Consumer
#last_heartbeat_at Lepus::Process
#lepus_acknowledge_message Lepus::Testing::RSpecMatchers
#lepus_nack_message Lepus::Testing::RSpecMatchers
#lepus_publish_message Lepus::Testing::RSpecMatchers
#lepus_reject_message Lepus::Testing::RSpecMatchers
#lepus_requeue_message Lepus::Testing::RSpecMatchers
#lifecycle_hooks Lepus::Supervisor::LifecycleHooks::ClassMethods
logger Lepus
#logger= Lepus::Configuration
management_api Lepus::Web
#management_api_url Lepus::Configuration
#matches? Lepus::Testing::RSpecMatchers::PublishLepusMessage
#matches? Lepus::Testing::RSpecMatchers::ProcessLepusMessage
message_builder Lepus::Testing
#messages Lepus::Testing::Exchange
#metadata Lepus::Message
#metadata Lepus::Processes::Base
#metadata Lepus::Consumers::Worker
#method_missing Lepus::Message::Metadata
#method_missing Lepus::Message::DeliveryInfo
#metrics Lepus::Prometheus::Collector
middleware_chain Lepus::Consumer
middleware_chain Lepus::Producer
#middlewares Lepus::MiddlewareChain
mime_for Lepus::Web
#mode= Lepus::Processes::Runnable
#mutate Lepus::Message
#name Lepus::Processes::Base
#name Lepus::Testing::Exchange
#name Lepus::Consumers::WorkerFactory
#on_start Lepus::Supervisor::LifecycleHooks::ClassMethods
#on_stop Lepus::Supervisor::LifecycleHooks::ClassMethods
#on_thread_error Lepus::Configuration
#options Lepus::Consumers::Config
path Lepus::ProcessRegistry
#path Lepus::ProcessRegistry::FileBackend
#path Lepus::ProcessRegistry::RabbitmqBackend
#payload Lepus::Message
#perform Lepus::Consumer
#pid Lepus::Processes::Base
#pool_size Lepus::ConnectionPool
#pool_size Lepus::Producers::Config
#pool_size Lepus::Consumers::WorkerFactory
#pool_timeout Lepus::Producers::Config
#pool_timeout Lepus::Consumers::WorkerFactory
#prefetch_count Lepus::Consumers::Config
#process_alive_threshold Lepus::Configuration
#process_delivery Lepus::Web::ConsumerExtensions
#process_delivery Lepus::Web::HandlerExtensions
#process_delivery Lepus::Consumer
#process_delivery Lepus::Consumers::Handler
#process_delivery Lepus::Prometheus::Instrumentation::HandlerExtensions
#process_heartbeat_interval Lepus::Configuration
#process_id Lepus::Processes::Registrable::InstanceMethods
#process_registry_backend Lepus::Configuration
#processed Lepus::Consumers::Stats
#procline Lepus::Processes::Procline
#producer Lepus::Configuration
#producer_config Lepus::Configuration
producer_messages Lepus::Testing
#producer_middleware_chain Lepus::Configuration
#producer_middlewares Lepus::Configuration
#prometheus_buckets Lepus::Configuration
prunable Lepus::Process
prune Lepus::Process
#prune Lepus::Process
#prune_processes Lepus::LogSubscriber
publish Lepus::Producer
#publish Lepus::Producer
#publish Lepus::Publisher
#publish_options Lepus::Message
#publish_options Lepus::Producers::Definition
publisher Lepus::Producer
#publisher Lepus::Producer
#queue Lepus::Web::ManagementAPI
#queue_name Lepus::Consumers::Config
#queues Lepus::Web::ManagementAPI
#rabbitmq_url Lepus::Configuration
#record_errored Lepus::Consumers::Stats
#record_processed Lepus::Consumers::Stats
#record_rejected Lepus::Consumers::Stats
#recover_from_connection_close Lepus::Configuration
#recovery_attempts Lepus::Configuration
#recovery_interval Lepus::Configuration
register Lepus::Process
#register_process Lepus::LogSubscriber
#rejected Lepus::Consumers::Stats
render_index Lepus::Web
#replace_fork Lepus::LogSubscriber
reset! Lepus::Producers::Hooks
reset! Lepus::ProcessRegistry
reset_backend! Lepus::ProcessRegistry
#respond_to_missing? Lepus::Message::Metadata
#respond_to_missing? Lepus::Message::DeliveryInfo
#retry_queue_args Lepus::Consumers::Config
#retry_queue_name Lepus::Consumers::Config
#rss_memory Lepus::Process
#run_process_callbacks Lepus::Processes::Callbacks::InstanceMethods
#run_process_callbacks Lepus::Consumers::WorkerFactory
#running? Lepus::Web::Aggregator
running? Lepus::Prometheus::Instrumentation::QueuePoller
#setup Lepus::Supervisor::Pidfile
#shutdown Lepus::ConnectionPool
#shutdown_process Lepus::LogSubscriber
#size Lepus::ConnectionPool
#size Lepus::MiddlewareChain
#size Lepus::Testing::Exchange
#stale_threshold Lepus::Web::Aggregator
#start Lepus::CLI
start Lepus::Supervisor
#start Lepus::Supervisor
#start Lepus::Web::Aggregator
start Lepus::ProcessRegistry
#start Lepus::Processes::Runnable
#start Lepus::ProcessRegistry::Backend
start Lepus::Prometheus::Instrumentation::QueuePoller
#start Lepus::ProcessRegistry::FileBackend
#start Lepus::ProcessRegistry::RabbitmqBackend
start Lepus::Web
start_aggregator Lepus::Web
start_management_api Lepus::Web
#start_process Lepus::LogSubscriber
#stats Lepus::Web::HandlerExtensions
#stop Lepus::Supervisor
#stop Lepus::Processes::Base
#stop Lepus::Web::Aggregator
stop Lepus::ProcessRegistry
#stop Lepus::Processes::Runnable
#stop Lepus::ProcessRegistry::Backend
stop Lepus::Prometheus::Instrumentation::QueuePoller
#stop Lepus::ProcessRegistry::FileBackend
#stop Lepus::ProcessRegistry::RabbitmqBackend
stop Lepus::Web
stop_aggregator Lepus::Web
stop_management_api Lepus::Web
stop_watching_queues Lepus::Prometheus
#supervised? Lepus::Process
#supervised_by Lepus::Processes::Supervised::InstanceMethods
#supports_block_expectations? Lepus::Testing::RSpecMatchers::PublishLepusMessage
#thread_error Lepus::LogSubscriber
#timeout Lepus::ConnectionPool
#to_exchange Lepus::Testing::RSpecMatchers::PublishLepusMessage
#to_h Lepus::Message
#to_h Lepus::Process
#to_h Lepus::Consumers::Stats
#to_h Lepus::Message::Metadata
#to_h Lepus::Message::DeliveryInfo
#to_json Lepus::ProcessRegistry::MessageBuilder
#to_publish_options Lepus::Message
total_messages Lepus::Testing::Exchange
#type Lepus::Prometheus::Collector
#underscore Lepus::Primitive::String
#unhandled_signal_error Lepus::LogSubscriber
update Lepus::ProcessRegistry
#update Lepus::ProcessRegistry::Backend
#update_attributes Lepus::Process
use Lepus::Consumer
use Lepus::Producer
#use Lepus::MiddlewareChain
#vhost Lepus::Web::ManagementAPI
#wait_until Lepus::Timer
watch_queues Lepus::Prometheus
#web Lepus::CLI
#web_show_all_exchanges Lepus::Web::ConfigExtensions
#with Lepus::Testing::RSpecMatchers::PublishLepusMessage
#with_app_id Lepus::Testing::MessageBuilder
#with_channel Lepus::Testing::MessageBuilder
#with_connection Lepus::ConnectionPool
#with_consumer_tag Lepus::Testing::MessageBuilder
#with_content_type Lepus::Testing::MessageBuilder
#with_correlation_id Lepus::Testing::MessageBuilder
#with_delivery_info Lepus::Testing::RSpecMatchers::ProcessLepusMessage
#with_delivery_info_attrs Lepus::Testing::MessageBuilder
#with_delivery_mode Lepus::Testing::MessageBuilder
#with_delivery_tag Lepus::Testing::MessageBuilder
#with_exchange Lepus::Testing::MessageBuilder
#with_expiration Lepus::Testing::MessageBuilder
#with_headers Lepus::Testing::MessageBuilder
#with_message Lepus::Testing::RSpecMatchers::ProcessLepusMessage
#with_message_id Lepus::Testing::MessageBuilder
#with_metadata Lepus::Testing::RSpecMatchers::ProcessLepusMessage
#with_metadata_attrs Lepus::Testing::MessageBuilder
#with_payload Lepus::Testing::MessageBuilder
#with_priority Lepus::Testing::MessageBuilder
#with_publishing Lepus::Producers::Hooks
#with_redelivered Lepus::Testing::MessageBuilder
#with_reply_to Lepus::Testing::MessageBuilder
#with_routing_key Lepus::Testing::RSpecMatchers::PublishLepusMessage
#with_routing_key Lepus::Testing::MessageBuilder
#with_timestamp Lepus::Testing::MessageBuilder
#with_type Lepus::Testing::MessageBuilder
#with_user_id Lepus::Testing::MessageBuilder
#without_publishing Lepus::Producers::Hooks
#worker Lepus::Configuration
#worker_name Lepus::Consumers::Config
#worker_threads Lepus::Consumers::Config
#wrap_in_app_executor Lepus::AppExecutor