diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-06-25 12:00:48 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-06-25 12:00:48 +0100 |
| commit | 63dcb6eb059686af62c54388beef21af2f9a8219 (patch) | |
| tree | dbd4e9a829a07ffc213487508632163639e64d2b /src | |
| parent | a8cc007914d86b098cd4912f6702e7deb214cb59 (diff) | |
| download | rabbitmq-server-git-63dcb6eb059686af62c54388beef21af2f9a8219.tar.gz | |
Replace some stuff I stripped out that's used by the Erlang client.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_writer.erl | 10 |
2 files changed, 11 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 7c90d98024..2482049693 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -41,6 +41,8 @@ -export([server_properties/0]). +-export([analyze_frame/3]). + -import(gen_tcp). -import(fprof). -import(inet). diff --git a/src/rabbit_writer.erl b/src/rabbit_writer.erl index 375e540e7f..403120f150 100644 --- a/src/rabbit_writer.erl +++ b/src/rabbit_writer.erl @@ -33,7 +33,7 @@ -include("rabbit.hrl"). -include("rabbit_framing.hrl"). --export([start/4, shutdown/1, mainloop/1]). +-export([start/4, start_link/4, shutdown/1, mainloop/1]). -export([send_command/2, send_command/3, send_command_and_signal_back/3, send_command_and_signal_back/4, send_command_and_notify/5]). -export([internal_send_command/4, internal_send_command/6]). @@ -50,6 +50,8 @@ -spec(start/4 :: (socket(), channel_number(), non_neg_integer(), protocol()) -> pid()). +-spec(start_link/4 :: + (socket(), channel_number(), non_neg_integer(), protocol()) -> pid()). -spec(send_command/2 :: (pid(), amqp_method_record()) -> 'ok'). -spec(send_command/3 :: (pid(), amqp_method_record(), content()) -> 'ok'). -spec(send_command_and_signal_back/3 :: (pid(), amqp_method(), pid()) -> 'ok'). @@ -73,6 +75,12 @@ start(Sock, Channel, FrameMax, Protocol) -> frame_max = FrameMax, protocol = Protocol}]). +start_link(Sock, Channel, FrameMax, Protocol) -> + spawn_link(?MODULE, mainloop, [#wstate{sock = Sock, + channel = Channel, + frame_max = FrameMax, + protocol = Protocol}]). + mainloop(State) -> receive Message -> ?MODULE:mainloop(handle_message(Message, State)) |