enter_mainloop(Identity, State) -> any()
flush(W::pid()) -> ok
internal_send_command(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), MethodRecord::rabbit_framing:amqp_method_record(), Protocol::rabbit_types:protocol()) -> ok
internal_send_command(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol()) -> ok
mainloop(Deb, State) -> any()
mainloop1(Deb, State) -> any()
maybe_gc_large_msg(Content::rabbit_types:content() | rabbit_types:message()) -> non_neg_integer()
maybe_gc_large_msg(Content::rabbit_types:content() | rabbit_types:message(), GCThreshold::undefined | non_neg_integer()) -> undefined | non_neg_integer()
msg_size(Content::rabbit_types:content() | rabbit_types:message()) -> non_neg_integer()
send_command(W::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok
send_command(W::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok
send_command_and_notify(W::pid(), Q::pid(), ChPid::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok
send_command_and_notify(W::pid(), Q::pid(), ChPid::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok
send_command_flow(W::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok
send_command_flow(W::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok
send_command_sync(W::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok
send_command_sync(W::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok
start(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name()) -> rabbit_types:ok(pid())
start(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean()) -> rabbit_types:ok(pid())
start(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean(), GCThreshold::undefined | non_neg_integer()) -> rabbit_types:ok(pid())
start_link(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name()) -> rabbit_types:ok(pid())
start_link(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean()) -> rabbit_types:ok(pid())
start_link(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean(), GCThreshold::undefined | non_neg_integer()) -> rabbit_types:ok(pid())
system_code_change(Misc::term(), Module::term(), OldVsn::term(), Extra::term()) -> {ok, term()}
system_continue(Parent::term(), Deb::term(), Wstate::#wstate{}) -> any()
system_terminate(Reason::term(), Parent::term(), Deb::term(), State::term()) -> no_return()
Generated by EDoc