body_size() = non_neg_integer()
class_id() = rabbit_framing:amqp_class_id()
content() = rabbit_types:undecoded_content()
frame() = {method, rabbit_framing:amqp_method_name(), binary()} | {content_header, class_id(), weight(), body_size(), binary()} | {content_body, binary()}
frame_type() = '?FRAME_METHOD' | '?FRAME_HEADER' | '?FRAME_BODY' | '?FRAME_OOB_METHOD' | '?FRAME_OOB_HEADER' | '?FRAME_OOB_BODY' | '?FRAME_TRACE' | '?FRAME_HEARTBEAT'
method() = rabbit_framing:amqp_method_record()
protocol() = rabbit_framing:protocol()
state() = {method, protocol()} | {content_header, method(), class_id(), protocol()} | {content_body, method(), body_size(), class_id(), protocol()}
weight() = non_neg_integer()
analyze_frame/3 | |
init/1 | |
process/2 |
analyze_frame(Type::frame_type(), Body::binary(), Protocol::protocol()) -> frame() | heartbeat | error
init(Protocol::protocol()) -> {ok, state()}
process(Frame::frame(), X2::state()) -> {ok, state()} | {ok, method(), state()} | {ok, method(), content(), state()} | {error, rabbit_types:amqp_error()}
Generated by EDoc