Table of Contents - mbus-1.0.0 Documentation
Classes and Modules
- Hash
- Messagebus
- Messagebus::Client
- Messagebus::Client::InitializationError
- Messagebus::Client::InvalidDestinationError
- Messagebus::ClusterMap
- Messagebus::Connection
- Messagebus::Consumer
- Messagebus::DottableHash
- Messagebus::ErrorFrameReceived
- Messagebus::InvalidAcknowledgementType
- Messagebus::InvalidDestination
- Messagebus::InvalidHost
- Messagebus::Logging
- Messagebus::Logging::MyLogger
- Messagebus::Message
- Messagebus::MessageReceiveTimeout
- Messagebus::MessageStatus
- Messagebus::Producer
- Messagebus::Swarm
- Messagebus::Swarm::Controller
- Messagebus::Swarm::Controller::BadConfigurationError
- Messagebus::Swarm::Drone
- Messagebus::Swarm::Drone::AbortProcessing
- Messagebus::Swarm::Drone::LoggingWorker
- Messagebus::Thrift
- Messagebus::Thrift::MessageInternal
- Messagebus::Thrift::MessagePayload
- Messagebus::Thrift::MessagePayloadType
- Stomp
- Stomp::Client
- Stomp::Connection
- Stomp::Error
- Stomp::Error::InvalidFormat
- Stomp::Error::InvalidMessageLength
- Stomp::Error::InvalidServerCommand
- Stomp::Error::MaxReconnectAttempts
- Stomp::Error::PacketParsingTimeout
- Stomp::Error::PacketReceiptTimeout
- Stomp::Message
Methods
- ::after_fork — Messagebus::Swarm::Controller
- ::after_fork_procs — Messagebus::Swarm::Controller
- ::create — Messagebus::Message
- ::create_message — Messagebus::Message
- ::create_message_from_message_internal — Messagebus::Message
- ::default_configuration — Messagebus::Swarm
- ::default_configuration= — Messagebus::Swarm
- ::default_port — Stomp::Connection
- ::define_thrift — Messagebus::Message
- ::delete_pid — Messagebus::Swarm::Controller
- ::get_message_from_thrift_binary — Messagebus::Message
- ::get_salted_payload — Messagebus::Message
- ::logger — Messagebus::Client
- ::logger — Messagebus::Swarm
- ::logger= — Messagebus::Swarm
- ::new — Messagebus::Client
- ::new — Messagebus::ClusterMap
- ::new — Messagebus::Connection
- ::new — Messagebus::Consumer
- ::new — Messagebus::DottableHash
- ::new — Messagebus::MessageStatus
- ::new — Messagebus::Message
- ::new — Messagebus::Producer
- ::new — Messagebus::Swarm::Drone
- ::new — Stomp::Client
- ::new — Stomp::Connection
- ::new — Stomp::Message
- ::open — Stomp::Client
- ::perform_on_destination — Messagebus::Swarm::Drone::LoggingWorker
- ::require_files — Messagebus::Swarm::Controller
- ::start — Messagebus::Client
- ::start — Messagebus::Consumer
- ::start — Messagebus::Swarm::Controller
- ::stop — Messagebus::Swarm::Controller
- ::swarm_control_logger — Messagebus::Swarm::Controller
- ::swarm_control_logger= — Messagebus::Swarm::Controller
- ::write_pid — Messagebus::Swarm::Controller
- #[] — Messagebus::DottableHash
- #[]= — Messagebus::DottableHash
- #__old_receive — Stomp::Connection
- #_receive — Stomp::Connection
- #_transmit — Stomp::Connection
- #abort — Stomp::Client
- #abort — Stomp::Connection
- #ack — Messagebus::Consumer
- #ack — Stomp::Connection
- #acknowledge — Stomp::Client
- #actual_publish — Messagebus::Producer
- #assoc — Messagebus::DottableHash
- #begin — Stomp::Client
- #begin — Stomp::Connection
- #binary? — Messagebus::Thrift::MessagePayload
- #blocking_on_receive? — Messagebus::Swarm::Drone
- #change_host — Stomp::Connection
- #check_and_refresh_connection — Messagebus::Producer
- #check_arguments! — Stomp::Client
- #check_refresh_required — Messagebus::Producer
- #client_ack? — Stomp::Connection
- #close — Stomp::Client
- #close_socket — Stomp::Connection
- #closed? — Stomp::Client
- #closed? — Stomp::Connection
- #cluster_producer_map — Messagebus::ClusterMap
- #commit — Stomp::Client
- #commit — Stomp::Connection
- #connect — Stomp::Connection
- #connection_frame — Stomp::Client
- #create_cluster — Messagebus::ClusterMap
- #credit — Messagebus::Consumer
- #credit — Stomp::Client
- #credit — Stomp::Connection
- #deep_stringify — Messagebus::DottableHash
- #delete — Messagebus::DottableHash
- #delete_subscription — Messagebus::Consumer
- #disconnect — Stomp::Connection
- #disconnect_receipt — Stomp::Client
- #do_with_timeout — Messagebus::Connection
- #empty? — Stomp::Message
- #error — Messagebus::Logging::MyLogger
- #extract_underlying_message_body — Messagebus::Swarm::Drone
- #fetch — Messagebus::DottableHash
- #fetch_serverlist — Messagebus::Consumer
- #fetch_uri — Messagebus::Consumer
- #filter_options — Stomp::Client
- #find — Messagebus::ClusterMap
- #find_listener — Stomp::Client
- #get_connection — Stomp::Client
- #get_dynamic_fetch_url — Messagebus::Consumer
- #has_key? — Messagebus::DottableHash
- #hashed_initialize — Stomp::Connection
- #headers — Messagebus::Client
- #host_params= — Messagebus::Connection
- #include? — Messagebus::DottableHash
- #increase_reconnect_delay — Stomp::Connection
- #insert_sentinel_value — Messagebus::Consumer
- #is_blank? — Stomp::Message
- #join — Stomp::Client
- #json? — Messagebus::Thrift::MessagePayload
- #keepalive — Messagebus::Consumer
- #keepalive — Stomp::Client
- #keepalive — Stomp::Connection
- #key? — Messagebus::DottableHash
- #load_destination — Messagebus::ClusterMap
- #log_params — Stomp::Connection
- #logger — Messagebus::Connection
- #logger — Messagebus::Consumer
- #max_reconnect_attempts? — Stomp::Connection
- #merge — Messagebus::DottableHash
- #merge! — Messagebus::DottableHash
- #message — Stomp::Error::InvalidFormat
- #message — Stomp::Error::InvalidServerCommand
- #message — Stomp::Error::InvalidMessageLength
- #message — Stomp::Error::PacketParsingTimeout
- #message — Stomp::Error::PacketReceiptTimeout
- #message — Stomp::Error::MaxReconnectAttempts
- #message_id — Messagebus::Message
- #message_properties — Messagebus::Message
- #message_properties= — Messagebus::Message
- #method_missing — Messagebus::DottableHash
- #nack — Messagebus::Consumer
- #nack — Stomp::Client
- #nack — Stomp::Connection
- #obj_send — Stomp::Client
- #obj_send — Stomp::Connection
- #open? — Stomp::Client
- #open? — Stomp::Connection
- #open_socket — Stomp::Connection
- #open_ssl_socket — Stomp::Connection
- #open_tcp_socket — Stomp::Connection
- #options= — Messagebus::Connection
- #parse_char — Stomp::Connection
- #parse_hosts — Stomp::Client
- #payload — Messagebus::Message
- #payload_type — Messagebus::Message
- #poll — Stomp::Connection
- #processing_loop — Messagebus::Swarm::Drone
- #publish — Messagebus::Client
- #publish — Messagebus::Producer
- #publish — Stomp::Client
- #publish — Stomp::Connection
- #publish_internal — Messagebus::Producer
- #receive — Messagebus::Consumer
- #receive — Stomp::Connection
- #receive_immediate — Messagebus::Consumer
- #receive_internal — Messagebus::Consumer
- #receive_timeout — Messagebus::Consumer
- #refine_params — Stomp::Connection
- #refresh_servers — Messagebus::Consumer
- #register_receipt_listener — Stomp::Client
- #reload_config_on_interval — Messagebus::Client
- #replace — Messagebus::DottableHash
- #respond_to? — Messagebus::DottableHash
- #running — Stomp::Client
- #send — Stomp::Client
- #set_subscription_id_if_missing — Stomp::Client
- #socket — Stomp::Connection
- #start — Messagebus::Client
- #start — Messagebus::ClusterMap
- #start — Messagebus::Consumer
- #start — Messagebus::Producer
- #start_listeners — Stomp::Client
- #start_server — Messagebus::Connection
- #start_servers — Messagebus::Consumer
- #started? — Messagebus::Connection
- #stop — Messagebus::Client
- #stop — Messagebus::ClusterMap
- #stop — Messagebus::Consumer
- #stop — Messagebus::Producer
- #stop — Messagebus::Swarm::Drone
- #stop_server — Messagebus::Connection
- #stop_servers — Messagebus::Consumer
- #stopped? — Messagebus::Connection
- #store — Messagebus::DottableHash
- #string? — Messagebus::Thrift::MessagePayload
- #stringify_keys — Messagebus::DottableHash
- #struct_fields — Messagebus::Thrift::MessagePayload
- #struct_fields — Messagebus::Thrift::MessageInternal
- #subscribe — Stomp::Client
- #subscribe — Stomp::Connection
- #subscribe_client — Messagebus::Consumer
- #symbolize_keys — Hash
- #to_s — Stomp::Message
- #to_thrift_binary — Messagebus::Message
- #transmit — Stomp::Connection
- #uncamelize_and_stringify_keys — Hash
- #uncamelize_and_symbolize_keys — Hash
- #unreceive — Stomp::Client
- #unreceive — Stomp::Connection
- #unsubscribe — Stomp::Client
- #unsubscribe — Stomp::Connection
- #update — Messagebus::DottableHash
- #update_cluster — Messagebus::ClusterMap
- #update_config — Messagebus::ClusterMap
- #url_regex — Stomp::Client
- #validate — Messagebus::Thrift::MessagePayload
- #validate — Messagebus::Thrift::MessageInternal
- #values_at — Messagebus::DottableHash
- #worker_perform — Messagebus::Swarm::Drone