Method List

Classes Methods Files

Search:

#== Bunny::Concurrent::AtomicFixnum
#=== Bunny::Concurrent::AtomicFixnum
#[] Bunny::GetResponse
#[] Bunny::DeliveryInfo
#[] Bunny::ReturnInfo
#[] Bunny::MessageProperties
#abort_on_exception Bunny::ConsumerWorkPool
#ack Bunny::Channel
#active Bunny::Channel
#add Bunny::Concurrent::SynchronizedSortedSet
#add_consumer Bunny::Channel
#addresses_from Bunny::Session
#after_recovery_attempts_exhausted Bunny::Session
#after_recovery_completed Bunny::Session
#allocated_channel_id? Bunny::ChannelIdAllocator
#announce_network_failure_recovery Bunny::Session
#any_consumers? Bunny::Channel
#any_threads_waiting? Bunny::Concurrent::Condition
#app_id Bunny::MessageProperties
#arguments Bunny::Queue
#arguments Bunny::Exchange
#arguments Bunny::Consumer
auth_mechanism Bunny::Authentication::CredentialsEncoder
#auto_delete? Bunny::Exchange
#auto_delete? Bunny::Queue
#automatic_acknowledgement? Bunny::Consumer
#automatically_recover? Bunny::Session
#backlog Bunny::ConsumerWorkPool
#basic_ack Bunny::Channel
#basic_cancel Bunny::Channel
#basic_consume Bunny::Channel
#basic_consume_with Bunny::Channel
#basic_get Bunny::Channel
#basic_nack Bunny::Channel
#basic_publish Bunny::Channel
#basic_qos Bunny::Channel
#basic_recover Bunny::Channel
#basic_reject Bunny::Channel
#before_recovery_attempt_starts Bunny::Session
#bind Bunny::Exchange
#bind Bunny::Queue
#blocked? Bunny::Session
#busy? Bunny::ConsumerWorkPool
#call Bunny::Consumer
#can_accept_queue_declare_ok? Bunny::Channel
#cancel Bunny::Consumer
#cause Bunny::NetworkFailure
#channel Bunny::ChannelAlreadyClosed
#channel Bunny::Consumer
#channel Bunny::Queue
#channel Bunny::GetResponse
#channel Bunny::DeliveryInfo
#channel Bunny::Exchange
#channel Bunny::ChannelLevelException
#channel_close Bunny::ChannelLevelException
#channel_flow Bunny::Channel
#channel_id_allocator Bunny::Session
#channel_level_exception_after_operation_that_has_no_response? Bunny::Channel
#channel_max Bunny::Session
#clean_up_and_fail_on_connection_close! Bunny::Session
#clean_up_on_shutdown Bunny::Session
#clear Bunny::Concurrent::ContinuationQueue
#clear Bunny::Concurrent::LinkedContinuationQueue
#client Bunny::Channel
#close Bunny::Channel
#close Bunny::Transport
#close Bunny::Session
#close_all_channels Bunny::Session
#close_channel Bunny::Session
#close_connection Bunny::Session
#close_transport Bunny::Session
#closed? Bunny::Channel
#closed? Bunny::Session
#closed? Bunny::Transport
#closing? Bunny::Session
#cluster_id Bunny::MessageProperties
#configure_socket Bunny::Transport
#configure_socket Bunny::Session
#configure_tls_context Bunny::Transport
#confirm_select Bunny::Channel
#connect Bunny::Transport
#connect_timeout Bunny::Transport
#connected? Bunny::Transport
#connecting? Bunny::Session
#connection Bunny::Channel
#connection Bunny::NotAllowedError
#connection Bunny::ConnectionLevelException
#connection_close Bunny::NotAllowedError
#connection_close Bunny::ConnectionLevelException
#connection_name Bunny::Session
#consumer Bunny::DeliveryInfo
#consumer_count Bunny::Queue
#consumer_tag Bunny::DeliveryInfo
#consumer_tag Bunny::Consumer
#consumers Bunny::Channel
#content_encoding Bunny::MessageProperties
#content_type Bunny::MessageProperties
#continuation_timeout Bunny::Session
#correlation_id Bunny::MessageProperties
#create_channel Bunny::Session
#declare! Bunny::Queue
decode Bunny::Framing::IO::Frame
decode Bunny::Framing::String::Frame
#decrement Bunny::Concurrent::AtomicFixnum
#decrement_recovery_attemp_counter! Bunny::Session
default Bunny::Exchange
#default_exchange Bunny::Channel
#delete Bunny::Concurrent::SynchronizedSortedSet
#delete Bunny::Queue
#delete Bunny::Exchange
#delete_if Bunny::Concurrent::SynchronizedSortedSet
#delivery_mode Bunny::MessageProperties
#delivery_tag Bunny::DeliveryInfo
#delivery_tag Bunny::GetResponse
#delivery_tag_offset Bunny::Channel
#deregister_exchange Bunny::Channel
#deregister_queue Bunny::Channel
#deregister_queue_named Bunny::Channel
#description Bunny::Concurrent::Condition
#direct Bunny::Channel
#disconnect_timeout Bunny::Transport
#durable? Bunny::Queue
#durable? Bunny::Exchange
#durable_queue Bunny::Channel
#each Bunny::GetResponse
#each Bunny::ReturnInfo
#each Bunny::MessageProperties
#each Bunny::DeliveryInfo
#empty? Bunny::Concurrent::ContinuationQueue
#encode_credentials Bunny::Authentication::ExternalMechanismEncoder
#encode_credentials Bunny::Authentication::CredentialsEncoder
#encode_credentials Bunny::Authentication::PlainMechanismEncoder
#exchange Bunny::DeliveryInfo
#exchange Bunny::GetResponse
#exchange Bunny::Channel
#exchange Bunny::ReturnInfo
#exchange_bind Bunny::Channel
#exchange_declare Bunny::Channel
#exchange_delete Bunny::Channel
#exchange_exists? Bunny::Session
#exchange_unbind Bunny::Channel
#exchanges Bunny::Channel
#exclusive Bunny::Consumer
#exclusive? Bunny::Queue
#expiration Bunny::MessageProperties
#fanout Bunny::Channel
#find_channel Bunny::Session
#find_exchange Bunny::Channel
#find_queue Bunny::Channel
#flow Bunny::Channel
#flush Bunny::Transport
for_session Bunny::Authentication::CredentialsEncoder
#frame_max Bunny::Session
#frame_size Bunny::Channel
#generate Bunny::ConsumerTagGenerator
#generate_consumer_tag Bunny::Channel
#generate_prefixed Bunny::ConsumerTagGenerator
#get Bunny::Concurrent::AtomicFixnum
#get_and_add Bunny::Concurrent::AtomicFixnum
#get_and_increment Bunny::Concurrent::AtomicFixnum
#handle_ack_or_nack Bunny::Channel
#handle_basic_get_empty Bunny::Channel
#handle_basic_get_ok Bunny::Channel
#handle_basic_return Bunny::Channel
#handle_cancellation Bunny::Consumer
#handle_frame Bunny::Session
#handle_frameset Bunny::Session
#handle_frameset Bunny::Channel
#handle_method Bunny::Channel
#handle_network_failure Bunny::Session
#handle_return Bunny::Exchange
#headers Bunny::Channel
#headers Bunny::MessageProperties
#heartbeat Bunny::Session
#heartbeat_from Bunny::Session
#heartbeat_interval Bunny::Session
#heartbeat_timeout Bunny::Session
#host Bunny::Transport
#host Bunny::Session
#host_from_address Bunny::Session
#host_with_port? Bunny::Session
#hostname Bunny::Session
#hostname Bunny::TCPConnectionFailed
#hostname Bunny::Transport
#id Bunny::Channel
#include? Bunny::Concurrent::SynchronizedSortedSet
#increment Bunny::Concurrent::AtomicFixnum
#increment_recoveries_counter Bunny::Channel
#initialize Bunny::Session
#initialize Bunny::Concurrent::LinkedContinuationQueue
#initialize Bunny::PossibleAuthenticationFailureError
#initialize Bunny::Concurrent::ContinuationQueue
#initialize Bunny::MessageProperties
#initialize Bunny::Concurrent::AtomicFixnum
#initialize Bunny::Exchange
#initialize Bunny::ConnectionClosedError
#initialize Bunny::ReturnInfo
#initialize Bunny::Concurrent::Condition
#initialize Bunny::BadLengthError
#initialize Bunny::NoFinalOctetError
#initialize Bunny::VersionedDeliveryTag
#initialize Bunny::AuthenticationFailureError
#initialize Bunny::HostListDepleted
#initialize Bunny::Consumer
#initialize Bunny::ConnectionLevelException
#initialize Bunny::ChannelAlreadyClosed
#initialize Bunny::TCPConnectionFailed
#initialize Bunny::Channel
#initialize Bunny::Transport
#initialize Bunny::TCPConnectionFailedForAllHosts
#initialize Bunny::NetworkErrorWrapper
#initialize Bunny::HeartbeatSender
#initialize Bunny::Queue
#initialize Bunny::ChannelIdAllocator
#initialize Bunny::NetworkFailure
#initialize Bunny::ChannelLevelException
#initialize Bunny::ReaderLoop
#initialize Bunny::DeliveryInfo
#initialize Bunny::ConnectionAlreadyClosed
#initialize Bunny::GetResponse
#initialize Bunny::NotAllowedError
#initialize Bunny::Concurrent::SynchronizedSortedSet
#initialize Bunny::ConsumerWorkPool
#initialize_socket Bunny::Transport
#inspect Bunny::Consumer
#inspect Bunny::ReturnInfo
#inspect Bunny::Channel
#inspect Bunny::DeliveryInfo
#inspect Bunny::Queue
#inspect Bunny::MessageProperties
#inspect Bunny::GetResponse
#inspect Bunny::Session
#instantiate_connection_level_exception Bunny::Session
#internal? Bunny::Exchange
#join Bunny::ConsumerWorkPool
#join Bunny::ReaderLoop
#kill Bunny::ReaderLoop
#kill Bunny::ConsumerWorkPool
known? Bunny::Queue::Types
#local_address Bunny::Transport
#local_port Bunny::Session
#logger Bunny::Session
#manual_acknowledgement? Bunny::Consumer
#manually_closed? Bunny::Session
#maybe_initialize_socket Bunny::Transport
#maybe_kill_consumer_work_pool! Bunny::Channel
#maybe_pause_consumer_work_pool! Bunny::Channel
#maybe_shutdown_reader_loop Bunny::Session
#maybe_start_consumer_work_pool! Bunny::Channel
#mechanism Bunny::Session
#message_count Bunny::Queue
#message_id Bunny::MessageProperties
message_in_kb Bunny::TestKit
#method_missing Bunny::Concurrent::LinkedContinuationQueue
monotonic Bunny::Timestamp
#mutex_impl Bunny::Session
#nack Bunny::Channel
#nacked_set Bunny::Channel
#name Bunny::Exchange
#name Bunny::Queue
#network_recovery_interval Bunny::Session
new Bunny
#next_channel_id Bunny::ChannelIdAllocator
#next_channel_id Bunny::Session
#next_publish_seq_no Bunny::Channel
#no_ack Bunny::Consumer
non_monotonic Bunny::Timestamp
non_monotonic_utc Bunny::Timestamp
#none_threads_waiting? Bunny::Concurrent::Condition
#notify Bunny::Concurrent::Condition
#notify_all Bunny::Concurrent::Condition
#notify_of_recovery_attempt_start Bunny::Session
#notify_of_recovery_attempts_exhausted Bunny::Session
#notify_of_recovery_completion Bunny::Session
now Bunny::Timestamp
#number Bunny::Channel
#on_blocked Bunny::Session
#on_cancellation Bunny::Consumer
#on_delivery Bunny::Consumer
#on_error Bunny::Channel
#on_return Bunny::Exchange
#on_unblocked Bunny::Session
#on_uncaught_exception Bunny::Channel
open Bunny::JRuby::Socket
#open Bunny::Channel
open Bunny::Socket
#open? Bunny::Transport
#open? Bunny::Session
#open? Bunny::Channel
#open_channel Bunny::Session
#options Bunny::Socket
#options Bunny::Queue
#opts Bunny::Exchange
#other Bunny::NetworkErrorWrapper
parse_uri Bunny::Session
#pass Bunny::Session
#password Bunny::Session
#password_from Bunny::Session
#pause Bunny::ConsumerWorkPool
#pending_server_named_queue_declaration? Bunny::Channel
ping! Bunny::Transport
#poll Bunny::Concurrent::LinkedContinuationQueue
#poll Bunny::Concurrent::ContinuationQueue
poll_until Bunny::TestKit
poll_while Bunny::TestKit
#pop Bunny::Concurrent::LinkedContinuationQueue
#pop Bunny::Queue
#pop Bunny::Concurrent::ContinuationQueue
#port Bunny::Session
#port Bunny::TCPConnectionFailed
#port Bunny::Transport
#port_from Bunny::Session
#port_from_address Bunny::Session
#post_initialize_socket Bunny::Transport
#predefined? Bunny::Exchange
#prefetch_count Bunny::Channel
#prefetch_global Bunny::Channel
#priority Bunny::MessageProperties
protocol_version Bunny
#publish Bunny::Exchange
#publish Bunny::Queue
#purge Bunny::Queue
#push Bunny::Concurrent::ContinuationQueue
#push Bunny::Concurrent::LinkedContinuationQueue
#queue Bunny::Consumer
#queue Bunny::Channel
#queue_bind Bunny::Channel
#queue_declare Bunny::Channel
#queue_delete Bunny::Channel
#queue_exists? Bunny::Session
#queue_name Bunny::Consumer
#queue_purge Bunny::Channel
#queue_unbind Bunny::Channel
#queues Bunny::Channel
#quorum_queue Bunny::Channel
#raise Bunny::ReaderLoop
#raise_if_continuation_resulted_in_a_connection_error! Bunny::Session
random_in_range Bunny::TestKit
reacheable? Bunny::Transport
#read_and_reset_only_acks_received Bunny::Channel
#read_fully Bunny::Socket
#read_fully Bunny::JRuby::Socket
#read_fully Bunny::Transport
#read_next_frame Bunny::Channel
#read_next_frame Bunny::Transport
#read_ready? Bunny::Transport
#read_timeout Bunny::Transport
#reader_loop Bunny::Session
#recover Bunny::Channel
#recover_bindings Bunny::Queue
#recover_cancelled_consumers! Bunny::Channel
#recover_channels Bunny::Session
#recover_confirm_mode Bunny::Channel
#recover_consumers Bunny::Channel
#recover_exchanges Bunny::Channel
#recover_from_connection_close? Bunny::Session
#recover_from_network_failure Bunny::Consumer
#recover_from_network_failure Bunny::Session
#recover_from_network_failure Bunny::Channel
#recover_from_network_failure Bunny::Queue
#recover_from_network_failure Bunny::Exchange
#recover_prefetch_setting Bunny::Channel
#recover_queues Bunny::Channel
#recover_tx_mode Bunny::Channel
#recoverable_exceptions Bunny::Session
#recoverable_network_failure? Bunny::Session
#recoveries_counter Bunny::Channel
#recovering_from_network_failure? Bunny::Session
#recovers_cancelled_consumers? Bunny::Channel
#recovery_attempts_limited? Bunny::Session
#redelivered Bunny::GetResponse
#redelivered Bunny::DeliveryInfo
#register_channel Bunny::Session
#register_consumer Bunny::Channel
#register_exchange Bunny::Channel
#register_queue Bunny::Channel
registry Bunny::Authentication::CredentialsEncoder
#reject Bunny::Channel
#release_all_continuations Bunny::Channel
#release_channel_id Bunny::Session
#release_channel_id Bunny::ChannelIdAllocator
#reply_code Bunny::ReturnInfo
#reply_text Bunny::ReturnInfo
#reply_to Bunny::MessageProperties
#reset_address_index Bunny::Session
#reset_channel_id_allocator Bunny::ChannelIdAllocator
#reset_recovery_attempt_counter! Bunny::Session
#resume Bunny::ConsumerWorkPool
#resume Bunny::ReaderLoop
#routing_key Bunny::GetResponse
#routing_key Bunny::DeliveryInfo
#routing_key Bunny::ReturnInfo
run Bunny
#run_loop Bunny::ReaderLoop
#run_once Bunny::ReaderLoop
#running? Bunny::ConsumerWorkPool
#send_frame Bunny::Session
#send_frame Bunny::Transport
#send_frame_without_timeout Bunny::Session
#send_frame_without_timeout Bunny::Transport
#send_frameset Bunny::Session
#send_frameset_without_timeout Bunny::Session
#send_raw_without_timeout Bunny::Session
#server_authentication_mechanisms Bunny::Session
#server_capabilities Bunny::Session
#server_locales Bunny::Session
#server_named? Bunny::Queue
#server_properties Bunny::Session
#session Bunny::Authentication::CredentialsEncoder
#session Bunny::Transport
#set Bunny::Concurrent::AtomicFixnum
#should_retry_recovery? Bunny::Session
#shutdown Bunny::ConsumerWorkPool
#signal_activity! Bunny::Session
#signal_activity! Bunny::HeartbeatSender
#size Bunny::ConsumerWorkPool
#size Bunny::Concurrent::ContinuationQueue
#socket Bunny::Transport
#socket_configurator Bunny::Session
#stale? Bunny::VersionedDeliveryTag
#start Bunny::Session
#start Bunny::HeartbeatSender
#start Bunny::ReaderLoop
#start Bunny::ConsumerWorkPool
#start_reader_loop Bunny::Session
#status Bunny::Exchange
#status Bunny::Session
#status Bunny::Channel
#status Bunny::Queue
#stop Bunny::ReaderLoop
#stop Bunny::HeartbeatSender
#stopped? Bunny::ReaderLoop
#stopping? Bunny::ReaderLoop
#stream Bunny::Channel
#submit Bunny::ConsumerWorkPool
#subscribe Bunny::Queue
#subscribe_with Bunny::Queue
#synchronised_find_channel Bunny::Session
#synchronize Bunny::Channel
#synchronize Bunny::ChannelIdAllocator
#tag Bunny::VersionedDeliveryTag
#temporary_queue Bunny::Channel
#terminate_with Bunny::ReaderLoop
#threaded Bunny::Session
#threaded? Bunny::Session
#threads Bunny::ConsumerWorkPool
#timestamp Bunny::MessageProperties
#tls_ca_certificates Bunny::Transport
#tls_certificate_path Bunny::Transport
#tls_context Bunny::Transport
#tls_key_path Bunny::Transport
#to_hash Bunny::MessageProperties
#to_hash Bunny::ReturnInfo
#to_hash Bunny::DeliveryInfo
#to_hash Bunny::GetResponse
#to_i Bunny::VersionedDeliveryTag
#to_s Bunny::Session
#to_s Bunny::Consumer
#to_s Bunny::Channel
#to_s Bunny::Queue
#to_s Bunny::DeliveryInfo
#to_s Bunny::MessageProperties
#to_s Bunny::GetResponse
#to_s Bunny::ReturnInfo
#topic Bunny::Channel
#transport Bunny::Session
#transport_write_timeout Bunny::Session
#tx_commit Bunny::Channel
#tx_rollback Bunny::Channel
#tx_select Bunny::Channel
#type Bunny::MessageProperties
#type Bunny::Exchange
#unbind Bunny::Exchange
#unbind Bunny::Queue
#unconfirmed_set Bunny::Channel
#unregister_channel Bunny::Session
#unregister_consumer Bunny::Channel
#update_secret Bunny::Session
#user Bunny::Session
#user_id Bunny::MessageProperties
#username Bunny::AuthenticationFailureError
#username Bunny::PossibleAuthenticationFailureError
#username Bunny::Session
#username_from Bunny::Session
#uses_ssl? Bunny::Transport
#uses_ssl? Bunny::Session
#uses_tls? Bunny::Transport
#uses_tls? Bunny::Session
#using_publisher_confirmations? Bunny::Channel
#using_tx? Bunny::Channel
#validate_connection_options Bunny::Session
#verify_peer Bunny::Transport
version Bunny
#version Bunny::VersionedDeliveryTag
#vhost Bunny::AuthenticationFailureError
#vhost Bunny::PossibleAuthenticationFailureError
#vhost Bunny::Session
#vhost_from Bunny::Session
#virtual_host Bunny::Session
#wait Bunny::Concurrent::Condition
#wait_for_confirms Bunny::Exchange
#wait_for_confirms Bunny::Channel
#wait_on_basic_get_continuations Bunny::Channel
#wait_on_confirms_continuations Bunny::Channel
#wait_on_continuations Bunny::Channel
#wait_on_continuations_timeout Bunny::Channel
#waiting_set_size Bunny::Concurrent::Condition
#waiting_threads Bunny::Concurrent::Condition
#with_channel Bunny::Session
#with_continuation_timeout Bunny::Channel
#work_pool Bunny::Channel
#write Bunny::Transport
#write_nonblock_fully Bunny::Socket
#write_timeout Bunny::Transport
#write_without_timeout Bunny::Transport