Method List

Classes Methods Files

Search:

#acknowledge Legion::Transport::Queue
#acknowledge Legion::Transport::InProcess::Channel
#acknowledge Legion::Transport::InProcess::Queue
active? Legion::Transport::Local
#after_recovery_attempts_exhausted Legion::Transport::InProcess::Session
#after_recovery_completed Legion::Transport::InProcess::Session
#app_id Legion::Transport::Message
apply_quorum_policy! Legion::Transport::Helpers::Policy
#basic_qos Legion::Transport::InProcess::Channel
#bind Legion::Transport::InProcess::Queue
#borrow Legion::Transport::Helpers::ChannelPool
brokers Legion::Transport::Kafka
build_channel Legion::Transport::Connection
#build_default_exchange Legion::Transport::Helper
build_session_open? Legion::Transport::Connection
cache_instance Legion::Transport::Exchange
cached_instance Legion::Transport::Exchange
#cancel Legion::Transport::InProcess::Consumer
#cancelled? Legion::Transport::InProcess::Consumer
#channel Legion::Transport::Common
#channel Legion::Transport::Message
#channel Legion::Transport::Exchange
channel Legion::Transport::Settings
channel Legion::Transport::Connection
#channel Legion::Transport::InProcess::Exchange
#channel Legion::Transport::InProcess::Queue
#channel_open? Legion::Transport::Common
channel_open? Legion::Transport::Connection
channel_thread Legion::Transport::Connection
check_publish Legion::Transport::TenantQuota
#checkin Legion::Transport::Helpers::Pool
#checkout Legion::Transport::Helpers::Pool
clear_cache Legion::Transport::Exchange
#close Legion::Transport::Common
#close Legion::Transport::InProcess::Session
#close Legion::Transport::InProcess::Channel
#close! Legion::Transport::Common
#close_all Legion::Transport::Helpers::ChannelPool
close_build_session Legion::Transport::Connection
#closed? Legion::Transport::InProcess::Session
#connected? Legion::Transport::Helpers::Pool
connection Legion::Transport::Settings
connector Legion::Transport::Connection
#consumer_tag Legion::Transport::Consumer
#consumer_tag Legion::Transport::InProcess::Consumer
#content_encoding Legion::Transport::Message
#content_encoding Legion::Transport::InProcess::MessageProperties
#content_type Legion::Transport::Message
#content_type Legion::Transport::InProcess::MessageProperties
#correlation_id Legion::Transport::Message
count Legion::Transport::Spool
#create_channel Legion::Transport::InProcess::Session
create_dedicated_session Legion::Transport::Connection
current_tenant_id Legion::Transport::TenantTopology
declare_all Legion::Transport::Queues::RegionOutbound
declare_outbound Legion::Transport::Queues::RegionOutbound
#decoded_payload Legion::Transport::Kafka::IncomingMessage
#deep_merge Legion::Transport::Common
default Legion::Transport::Settings
#default_exchange Legion::Transport::Helper
default_group Legion::Transport::Kafka
#default_options Legion::Transport::Queue
#default_options Legion::Transport::Exchange
#default_type Legion::Transport::Exchange
#delete Legion::Transport::Queue
#delete Legion::Transport::Exchange
#delete Legion::Transport::InProcess::Exchange
#delete Legion::Transport::InProcess::Queue
#delete_exchange Legion::Transport::Exchange
#delivery_tag Legion::Transport::InProcess::DeliveryInfo
deprovision Legion::Transport::TenantProvisioner
#dlx_enabled Legion::Transport::Queue
#dlx_exchange_name Legion::Transport::Queue
drain Legion::Transport::Spool
enabled? Legion::Transport::Kafka
enabled? Legion::Transport::TenantQuota
enabled? Legion::Transport::TenantTopology
#encode_message Legion::Transport::Message
#encrypt? Legion::Transport::Message
#encrypt? Legion::Transport::Messages::RequestClusterSecret
#encrypt_message Legion::Transport::Message
#ensure_dlx Legion::Transport::Queue
ensure_topic Legion::Transport::Kafka
ensure_topic Legion::Transport::Kafka::Admin
evict_stale Legion::Transport::Spool
#exchange Legion::Transport::Message
#exchange Legion::Transport::InProcess::DeliveryInfo
#exchange Legion::Transport::Messages::Task
#exchange Legion::Transport::Messages::Dynamic
#exchange Legion::Transport::Messages::SubTask
#exchange Legion::Transport::Messages::TaskLog
#exchange Legion::Transport::Messages::TaskUpdate
#exchange Legion::Transport::Messages::LexRegister
#exchange Legion::Transport::Messages::CheckSubtask
#exchange Legion::Transport::Messages::RegionReRoute
#exchange Legion::Transport::Messages::RequestClusterSecret
#exchange_declare Legion::Transport::InProcess::Channel
#exchange_delete Legion::Transport::InProcess::Channel
#exchange_name Legion::Transport::Message
#exchange_name Legion::Transport::Exchange
#exchange_name Legion::Transport::Exchanges::Node
#exchange_name Legion::Transport::Exchanges::Task
#exchange_name Legion::Transport::Exchanges::Agent
#exchange_name Legion::Transport::Exchanges::Crypt
exchange_name Legion::Transport::TenantTopology
#exchange_name Legion::Transport::Exchanges::Logging
#exchange_name Legion::Transport::Exchanges::Extensions
#exchange_name Legion::Transport::Messages::CheckSubtask
#exchange_options Legion::Transport::Exchange
#exchanges Legion::Transport::Helper
exchanges Legion::Transport::Settings
#expiration Legion::Transport::Message
force_reconnect Legion::Transport::Connection
#function Legion::Transport::Messages::Dynamic
#generate_consumer_tag Legion::Transport::Common
#generate_task? Legion::Transport::Messages::TaskLog
#headers Legion::Transport::Message
#headers Legion::Transport::InProcess::MessageProperties
#headers Legion::Transport::Kafka::IncomingMessage
#initialize Legion::Transport::Queue
#initialize Legion::Transport::Message
#initialize Legion::Transport::Consumer
#initialize Legion::Transport::Exchange
#initialize Legion::Transport::InProcess::Session
#initialize Legion::Transport::InProcess::Channel
#initialize Legion::Transport::InProcess::Exchange
#initialize Legion::Transport::InProcess::Queue
#initialize Legion::Transport::InProcess::Consumer
#initialize Legion::Transport::Helpers::Pool
#initialize Legion::Transport::Queues::Agent
#initialize Legion::Transport::Helpers::ChannelPool
#initialize Legion::Transport::Kafka::IncomingMessage
#inspect Legion::Transport::Kafka::IncomingMessage
instance_cache Legion::Transport::Exchange
kafka Legion::Transport::Settings
kafka_settings Legion::Transport::Kafka
#key Legion::Transport::Kafka::IncomingMessage
lite_mode? Legion::Transport::Connection
log_channel Legion::Transport::Connection
logger Legion::Transport
max_file_bytes Legion::Transport::Spool
max_payload_bytes Legion::Transport::Message
#message Legion::Transport::Message
#message Legion::Transport::Messages::Task
#message Legion::Transport::Messages::Dynamic
#message Legion::Transport::Messages::SubTask
#message Legion::Transport::Messages::TaskLog
#message Legion::Transport::Messages::RegionReRoute
#message Legion::Transport::Messages::RequestClusterSecret
#message_id Legion::Transport::Message
#messages Legion::Transport::Helper
messages Legion::Transport::Settings
#nack_or_dlq Legion::Transport::Queue
#name Legion::Transport::InProcess::Exchange
#name Legion::Transport::InProcess::Queue
new Legion::Transport::Connection
#offset Legion::Transport::Kafka::IncomingMessage
#on_blocked Legion::Transport::InProcess::Session
on_force_reconnect Legion::Transport::Connection
#on_unblocked Legion::Transport::InProcess::Session
#open? Legion::Transport::InProcess::Session
#open? Legion::Transport::InProcess::Channel
open_build_session Legion::Transport::Connection
#open_channel Legion::Transport::Common
#options Legion::Transport::Messages::Dynamic
#options_builder Legion::Transport::Common
#own_queue? Legion::Transport::Queue
#partition Legion::Transport::Kafka::IncomingMessage
#passive? Legion::Transport::Queue
#passive? Legion::Transport::Exchange
#payload Legion::Transport::Kafka::IncomingMessage
#persistent Legion::Transport::Message
#prefetch Legion::Transport::InProcess::Channel
#priority Legion::Transport::Message
provision Legion::Transport::TenantProvisioner
publish Legion::Transport::Kafka
publish Legion::Transport::Local
#publish Legion::Transport::Message
#publish Legion::Transport::InProcess::Exchange
publish Legion::Transport::Kafka::Producer
#purge_closed Legion::Transport::Helpers::ChannelPool
queue_depth Legion::Transport::Local
#queue_name Legion::Transport::Queue
#queue_name Legion::Transport::Queues::Node
#queue_name Legion::Transport::Queues::Agent
#queue_name Legion::Transport::Queues::TaskLog
queue_name Legion::Transport::TenantTopology
#queue_name Legion::Transport::Queues::NodeCrypt
#queue_name Legion::Transport::Queues::NodeStatus
#queue_name Legion::Transport::Queues::TaskUpdate
queue_name_for Legion::Transport::Queues::RegionOutbound
#queue_options Legion::Transport::Queue
#queue_options Legion::Transport::Queues::Node
#queue_options Legion::Transport::Queues::Agent
#queue_options Legion::Transport::Queues::TaskLog
#queue_options Legion::Transport::Queues::NodeCrypt
#queue_options Legion::Transport::Queues::NodeStatus
#queue_options Legion::Transport::Queues::TaskUpdate
#queues Legion::Transport::Helper
queues Legion::Transport::Settings
#raw Legion::Transport::Kafka::IncomingMessage
reconnect Legion::Transport::Connection
#recreate_queue Legion::Transport::Queue
register_discovery Legion::Transport::Routes
register_helpers Legion::Transport::Routes
register_json_helpers Legion::Transport::Routes
register_publish Legion::Transport::Routes
register_routes Legion::Transport
register_status Legion::Transport::Routes
register_transport_helpers Legion::Transport::Routes
registered Legion::Transport::Routes
#reject Legion::Transport::Queue
#reject Legion::Transport::InProcess::Channel
#reject Legion::Transport::InProcess::Queue
replay Legion::Transport::Kafka
replay Legion::Transport::Kafka::Consumer
#reply_to Legion::Transport::Message
reset! Legion::Transport::Kafka
reset! Legion::Transport::Local
reset! Legion::Transport::Spool
reset! Legion::Transport::TenantQuota
reset! Legion::Transport::Kafka::Consumer
reset! Legion::Transport::Kafka::Producer
resolve_hosts Legion::Transport::Settings
resolve_log_level Legion::Transport::Settings
#return Legion::Transport::Helpers::ChannelPool
#routing_key Legion::Transport::Message
#routing_key Legion::Transport::InProcess::DeliveryInfo
#routing_key Legion::Transport::Messages::Task
#routing_key Legion::Transport::Messages::Dynamic
#routing_key Legion::Transport::Messages::SubTask
#routing_key Legion::Transport::Messages::TaskLog
#routing_key Legion::Transport::Messages::TaskUpdate
#routing_key Legion::Transport::Messages::LexRegister
#routing_key Legion::Transport::Messages::CheckSubtask
#routing_key Legion::Transport::Messages::RegionReRoute
#routing_key Legion::Transport::Messages::RequestClusterSecret
session Legion::Transport::Connection
session_open? Legion::Transport::Connection
settings Legion::Transport
settings Legion::Transport::Connection
setup Legion::Transport::Local
setup Legion::Transport::Spool
setup Legion::Transport::Connection
shared? Legion::Transport::TenantTopology
shutdown Legion::Transport::Connection
#shutdown Legion::Transport::Helpers::Pool
#size Legion::Transport::Helpers::Pool
#size Legion::Transport::Helpers::ChannelPool
#start Legion::Transport::InProcess::Session
subscribe Legion::Transport::Kafka
subscribe Legion::Transport::Local
#subscribe Legion::Transport::InProcess::Queue
subscribe Legion::Transport::Kafka::Consumer
tenant_topology Legion::Transport::Settings
#timestamp Legion::Transport::Message
#timestamp Legion::Transport::InProcess::MessageProperties
#timestamp Legion::Transport::Kafka::IncomingMessage
#tls_options Legion::Transport::Connection::SSL
#to_s Legion::Transport::Kafka::IncomingMessage
#topic Legion::Transport::Kafka::IncomingMessage
#transport_channel Legion::Transport::Helper
#transport_channel_open? Legion::Transport::Helper
#transport_class Legion::Transport::Helper
#transport_connected? Legion::Transport::Helper
#transport_default_ttl Legion::Transport::Helper
#transport_lite_mode? Legion::Transport::Helper
#transport_path Legion::Transport::Helper
#transport_publish Legion::Transport::Helper
#transport_session_open? Legion::Transport::Helper
#transport_spool_count Legion::Transport::Helper
#type Legion::Transport::Message
#type Legion::Transport::InProcess::Exchange
#type Legion::Transport::Messages::Dynamic
#type Legion::Transport::Messages::RequestClusterSecret
#user_id Legion::Transport::Message
#valid_status Legion::Transport::Messages::TaskUpdate
#validate Legion::Transport::Message
#validate Legion::Transport::Messages::Task
#validate Legion::Transport::Messages::SubTask
#validate Legion::Transport::Messages::TaskLog
#validate Legion::Transport::Messages::LexRegister
#validate Legion::Transport::Messages::CheckSubtask
#validate Legion::Transport::Messages::RegionReRoute
#validate Legion::Transport::Messages::RequestClusterSecret
#vault_pki_enabled? Legion::Transport::Connection::Vault
#vault_pki_tls_options Legion::Transport::Connection::Vault
write Legion::Transport::Spool