Module rabbit_command_assembler

Data Types

body_size()

body_size() = non_neg_integer()

class_id()

class_id() = rabbit_framing:amqp_class_id()

content()

content() = rabbit_types:undecoded_content()

frame()

frame() = {method, rabbit_framing:amqp_method_name(), binary()} | {content_header, class_id(), weight(), body_size(), binary()} | {content_body, binary()}

frame_type()

frame_type() = '?FRAME_METHOD' | '?FRAME_HEADER' | '?FRAME_BODY' | '?FRAME_OOB_METHOD' | '?FRAME_OOB_HEADER' | '?FRAME_OOB_BODY' | '?FRAME_TRACE' | '?FRAME_HEARTBEAT'

method()

method() = rabbit_framing:amqp_method_record()

protocol()

protocol() = rabbit_framing:protocol()

state()

state() = {method, protocol()} | {content_header, method(), class_id(), protocol()} | {content_body, method(), body_size(), class_id(), protocol()}

weight()

weight() = non_neg_integer()

Function Index

analyze_frame/3
init/1
process/2

Function Details

analyze_frame/3

analyze_frame(Type::frame_type(), Body::binary(), Protocol::protocol()) -> frame() | heartbeat | error

init/1

init(Protocol::protocol()) -> {ok, state()}

process/2

process(Frame::frame(), X2::state()) -> {ok, state()} | {ok, method(), state()} | {ok, method(), content(), state()} | {error, rabbit_types:amqp_error()}


Generated by EDoc