Method List

Classes Methods Files

Search:

#<< OMQ::Writable
#add_queue OMQ::Routing::FairQueue
#alive? OMQ::Engine::SocketLifecycle
#all_peers_gone OMQ::Engine
#all_peers_gone OMQ::Socket
#all_peers_gone OMQ::Engine::SocketLifecycle
apply_buffer_sizes OMQ::Transport::IPC
apply_buffer_sizes OMQ::Transport::TCP
#attach_endpoints OMQ::Socket
#barrier OMQ::Engine
#barrier OMQ::Engine::SocketLifecycle
#barrier OMQ::Engine::ConnectionLifecycle
#bind OMQ::Engine
bind OMQ::Socket
#bind OMQ::Socket
bind OMQ::Transport::IPC
bind OMQ::Transport::TCP
bind OMQ::Transport::Inproc
#build_fatal_error OMQ::Engine
build_queue OMQ::Routing
#capture_parent_task OMQ::Engine
#capture_parent_task OMQ::Engine::SocketLifecycle
#close OMQ::Engine
#close OMQ::Socket
#close OMQ::Transport::Inproc::DirectPipe
#close! OMQ::Engine::ConnectionLifecycle
#close_read OMQ::Socket
#closed? OMQ::Engine
#closed? OMQ::Engine::SocketLifecycle
#closing? OMQ::Engine::SocketLifecycle
#conflate OMQ::Options
#conn OMQ::Engine::ConnectionLifecycle
#connect OMQ::Engine
connect OMQ::Socket
#connect OMQ::Socket
connect OMQ::Transport::IPC
connect OMQ::Transport::TCP
connect OMQ::Transport::Inproc
connect_timeout OMQ::Transport::TCP
#connection_added OMQ::Routing::Pub
#connection_added OMQ::Routing::Rep
#connection_added OMQ::Routing::Req
#connection_added OMQ::Routing::Sub
#connection_added OMQ::Routing::Pair
#connection_added OMQ::Routing::Pull
#connection_added OMQ::Routing::Push
#connection_added OMQ::Routing::XPub
#connection_added OMQ::Routing::XSub
#connection_added OMQ::Routing::Dealer
#connection_added OMQ::Routing::Router
#connection_count OMQ::Socket
#connection_lost OMQ::Engine
#connection_ready OMQ::Engine
#connection_removed OMQ::Routing::Pub
#connection_removed OMQ::Routing::Rep
#connection_removed OMQ::Routing::Req
#connection_removed OMQ::Routing::Sub
#connection_removed OMQ::Routing::Pair
#connection_removed OMQ::Routing::Pull
#connection_removed OMQ::Routing::Push
#connection_removed OMQ::Routing::XPub
#connection_removed OMQ::Routing::XSub
#connection_removed OMQ::Routing::Dealer
#connection_removed OMQ::Routing::Router
#connection_wrapper OMQ::Engine
#connections OMQ::Engine
#dequeue OMQ::DropQueue
#dequeue OMQ::QueueReadable
#dequeue OMQ::Routing::FairQueue
#dequeue OMQ::Routing::SignalingQueue
#dequeue_recv OMQ::Engine
#dequeue_recv OMQ::Routing::Pub
#dequeue_recv OMQ::Routing::Sub
#dequeue_recv OMQ::Routing::Push
#dequeue_recv OMQ::Routing::XPub
#dequeue_recv OMQ::Routing::XSub
#dequeue_recv OMQ::Routing::FairRecv
#dequeue_recv_sentinel OMQ::Engine
#detail OMQ::MonitorEvent
#detail OMQ
#direct_recv_queue OMQ::Transport::Inproc::DirectPipe
#direct_recv_transform OMQ::Transport::Inproc::DirectPipe
#disconnect OMQ::Engine
#disconnect OMQ::Socket
drain_send_queue OMQ::Routing
#each OMQ::QueueReadable
#emit_monitor_event OMQ::Engine
#emit_verbose_monitor_event OMQ::Engine
#emit_verbose_msg_received OMQ::Engine
#emit_verbose_msg_sent OMQ::Engine
#empty? OMQ::DropQueue
#empty? OMQ::Routing::FairQueue
#empty? OMQ::Routing::SignalingQueue
#encrypted? OMQ::Transport::Inproc::DirectPipe
#endpoint OMQ::MonitorEvent
#endpoint OMQ
#endpoint OMQ::Transport::IPC::Listener
#endpoint OMQ::Transport::TCP::Listener
#endpoint OMQ::Transport::Inproc::Listener
#endpoint OMQ::Engine::ConnectionLifecycle
#engine OMQ::Socket
#enqueue OMQ::DropQueue
#enqueue OMQ::Routing::Pub
#enqueue OMQ::Routing::Rep
#enqueue OMQ::Routing::Req
#enqueue OMQ::Routing::Sub
#enqueue OMQ::Routing::Pair
#enqueue OMQ::Routing::Pull
#enqueue OMQ::Routing::Push
#enqueue OMQ::Routing::XPub
#enqueue OMQ::Routing::XSub
#enqueue OMQ::Routing::Dealer
#enqueue OMQ::Routing::Router
#enqueue OMQ::QueueWritable
#enqueue OMQ::Routing::SignalingQueue
#enqueue_send OMQ::Engine
#finalize_init OMQ::Socket
#finish_closing! OMQ::Engine::SocketLifecycle
#flush OMQ::Transport::Inproc::DirectPipe
for OMQ::Routing
freeze_for_ractors! OMQ
#handle_accepted OMQ::Engine
#handle_connected OMQ::Engine
#handshake! OMQ::Engine::ConnectionLifecycle
#heartbeat_interval OMQ::Options
#heartbeat_timeout OMQ::Options
#heartbeat_ttl OMQ::Options
#identity OMQ::Options
#init_engine OMQ::Socket
#initialize OMQ::PAIR
#initialize OMQ::Engine
#initialize OMQ::Socket
#initialize OMQ::Options
#initialize OMQ::PUB
#initialize OMQ::SUB
#initialize OMQ::XPUB
#initialize OMQ::XSUB
#initialize OMQ::REQ
#initialize OMQ::REP
#initialize OMQ::PUSH
#initialize OMQ::PULL
#initialize OMQ::DropQueue
#initialize OMQ::Routing::Pub
#initialize OMQ::Routing::Rep
#initialize OMQ::Routing::Req
#initialize OMQ::Routing::Sub
#initialize OMQ::Routing::Pair
#initialize OMQ::Routing::Pull
#initialize OMQ::Routing::Push
#initialize OMQ::Routing::XPub
#initialize OMQ::Routing::XSub
#initialize OMQ::MonitorEvent
#initialize OMQ::DEALER
#initialize OMQ::ROUTER
#initialize OMQ::Transport::IPC::Listener
#initialize OMQ::Transport::TCP::Listener
#initialize OMQ::Routing::Dealer
#initialize OMQ::Routing::Router
#initialize OMQ::Engine::Reconnect
#initialize OMQ::Engine::RecvPump
#initialize OMQ::Transport::Inproc::Listener
#initialize OMQ::Routing::FairQueue
#initialize OMQ::Routing::SignalingQueue
#initialize OMQ::Engine::SocketLifecycle
#initialize OMQ::Engine::ConnectionLifecycle
#initialize OMQ::Transport::Inproc::DirectPipe
#inspect OMQ::Socket
#last_endpoint OMQ::Engine
#last_endpoint OMQ::Socket
#last_tcp_port OMQ::Engine
#last_tcp_port OMQ::Socket
#lifecycle OMQ::Engine
#linger OMQ::Options
loopback_host OMQ::Transport::TCP
#lost! OMQ::Engine::ConnectionLifecycle
#max_message_size OMQ::Options
#maybe_reconnect OMQ::Engine
#mechanism OMQ::Options
#monitor OMQ::Socket
normalize_bind_host OMQ::Transport::TCP
normalize_connect_host OMQ::Transport::TCP
#on_io_thread OMQ::Engine::SocketLifecycle
#on_mute OMQ::Options
#open? OMQ::Engine::SocketLifecycle
#options OMQ::Engine
#options OMQ::Socket
#parent_task OMQ::Engine
#parent_task OMQ::Engine::SocketLifecycle
parse_endpoint OMQ::Transport::TCP
#peer OMQ::Transport::Inproc::DirectPipe
#peer_connected OMQ::Engine
#peer_connected OMQ::Socket
#peer_connected OMQ::Engine::SocketLifecycle
#peer_identity OMQ::Transport::Inproc::DirectPipe
#peer_socket_type OMQ::Transport::Inproc::DirectPipe
#port OMQ::Transport::TCP::Listener
#push OMQ::Routing::FairQueue
#push OMQ::Routing::SignalingQueue
#qos OMQ::Options
#rcvbuf OMQ::Options
#read_frame OMQ::Transport::Inproc::DirectPipe
#read_timeout OMQ::Options
#ready_direct! OMQ::Engine::ConnectionLifecycle
#receive OMQ::Readable
#receive_message OMQ::Transport::Inproc::DirectPipe
#reconnect_enabled OMQ::Engine::SocketLifecycle
#reconnect_enabled= OMQ::Engine
#reconnect_enabled= OMQ::Socket
#reconnect_interval OMQ::Options
#record_disconnect_reason OMQ::Engine::ConnectionLifecycle
#recv_hwm OMQ::Options
#recv_queue OMQ::Routing::Pub
#recv_queue OMQ::Routing::Rep
#recv_queue OMQ::Routing::Req
#recv_queue OMQ::Routing::Sub
#recv_queue OMQ::Routing::Pair
#recv_queue OMQ::Routing::Pull
#recv_queue OMQ::Routing::Push
#recv_queue OMQ::Routing::XPub
#recv_queue OMQ::Routing::XSub
#recv_queue OMQ::Routing::Dealer
#recv_queue OMQ::Routing::Router
register OMQ::Routing
registry OMQ::Routing
#remove_queue OMQ::Routing::FairQueue
reset! OMQ::Transport::Inproc
#resolve_all_peers_gone_if_empty OMQ::Engine
#resolve_all_peers_gone_if_empty OMQ::Engine::SocketLifecycle
root_task OMQ::Reactor
#router_mandatory OMQ::Options
#routing OMQ::Engine
run OMQ::Reactor
#run OMQ::Engine::Reconnect
schedule OMQ::Engine::Reconnect
#send OMQ::Writable
#send OMQ::SingleFrame
#send_command OMQ::Transport::Inproc::DirectPipe
#send_hwm OMQ::Options
#send_message OMQ::Transport::Inproc::DirectPipe
#send_queues_drained? OMQ::Routing::Rep
#send_queues_drained? OMQ::Routing::Pair
#send_queues_drained? OMQ::Routing::XSub
#send_queues_drained? OMQ::Routing::Router
#send_queues_drained? OMQ::Routing::FanOut
#send_queues_drained? OMQ::Routing::RoundRobin
#send_to OMQ::ROUTER
#server OMQ::Transport::IPC::Listener
#servers OMQ::Transport::TCP::Listener
#set_unbounded OMQ::Socket
#signal OMQ::Routing::FairQueue
#signal_fatal_error OMQ::Engine
#sndbuf OMQ::Options
#socket_type OMQ::Engine
#spawn_conn_pump_task OMQ::Engine
#spawn_inproc_retry OMQ::Engine
#spawn_pump_task OMQ::Engine
start OMQ::Engine::Heartbeat
start OMQ::Engine::RecvPump
#start OMQ::Engine::RecvPump
start OMQ::Engine::Maintenance
start OMQ::Routing::ConnSendPump
#start_accept_loops OMQ::Transport::IPC::Listener
#start_accept_loops OMQ::Transport::TCP::Listener
#start_closing! OMQ::Engine::SocketLifecycle
#start_recv_pump OMQ::Engine
#state OMQ::Engine::SocketLifecycle
#state OMQ::Engine::ConnectionLifecycle
#stop OMQ::Engine
#stop OMQ::Socket
#stop OMQ::Routing::Pub
#stop OMQ::Routing::Rep
#stop OMQ::Routing::Req
#stop OMQ::Routing::Sub
#stop OMQ::Routing::Pair
#stop OMQ::Routing::Pull
#stop OMQ::Routing::Push
#stop OMQ::Routing::XPub
#stop OMQ::Routing::XSub
#stop OMQ::Transport::IPC::Listener
#stop OMQ::Transport::TCP::Listener
#stop OMQ::Routing::Dealer
#stop OMQ::Routing::Router
#stop OMQ::Transport::Inproc::Listener
stop! OMQ::Reactor
#subscribe OMQ::SUB
#subscribe OMQ::Routing::Sub
#subscriber_joined OMQ::Socket
#subscriber_joined OMQ::Routing::FanOut
#tasks OMQ::Engine
track_linger OMQ::Reactor
#transport_for OMQ::Engine
transports OMQ::Engine
#type OMQ::MonitorEvent
#type OMQ
#unbind OMQ::Engine
#unbind OMQ::Socket
unbind OMQ::Transport::Inproc
#unblock_recv OMQ::Routing::Pub
#unblock_recv OMQ::Routing::Sub
#unblock_recv OMQ::Routing::Push
#unblock_recv OMQ::Routing::XPub
#unblock_recv OMQ::Routing::XSub
#unblock_recv OMQ::Routing::FairRecv
#unsubscribe OMQ::SUB
#unsubscribe OMQ::Routing::Sub
untrack_linger OMQ::Reactor
validate_endpoint! OMQ::Transport::TCP
#verbose_monitor OMQ::Engine
#wait OMQ::QueueReadable
#wait_readable OMQ::Readable
#wait_writable OMQ::Writable
#write_messages OMQ::Transport::Inproc::DirectPipe
#write_timeout OMQ::Options