summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVlad Alexandru Ionescu <vlad@rabbitmq.com>2010-09-01 10:46:27 +0100
committerVlad Alexandru Ionescu <vlad@rabbitmq.com>2010-09-01 10:46:27 +0100
commit5dff66f593a26c42759b3f4f3507ed98142a0047 (patch)
treed5319dc8c1daf434844daba0f70ec9be23b9348e
parent9bd5378eb6e56143f558254483be2307ded441b1 (diff)
downloadrabbitmq-server-5dff66f593a26c42759b3f4f3507ed98142a0047.tar.gz
fixing unreachable function clause
-rw-r--r--src/rabbit_writer.erl12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_writer.erl b/src/rabbit_writer.erl
index fd5b5ba5..d641671b 100644
--- a/src/rabbit_writer.erl
+++ b/src/rabbit_writer.erl
@@ -127,12 +127,6 @@ handle_message({send_command, MethodRecord, Content},
ok = internal_send_command_async(Sock, Channel, MethodRecord,
Content, FrameMax, Protocol),
State;
-handle_message({send_command_sync, From, MethodRecord},
- State = #wstate{sock = Sock, channel = Channel,
- protocol = Protocol}) ->
- ok = internal_send_command_async(Sock, Channel, MethodRecord, Protocol),
- gen_server:reply(From, ok),
- State;
handle_message({send_command_sync, From, {MethodRecord, Content}},
State = #wstate{sock = Sock,
channel = Channel,
@@ -142,6 +136,12 @@ handle_message({send_command_sync, From, {MethodRecord, Content}},
Content, FrameMax, Protocol),
gen_server:reply(From, ok),
State;
+handle_message({send_command_sync, From, MethodRecord},
+ State = #wstate{sock = Sock, channel = Channel,
+ protocol = Protocol}) ->
+ ok = internal_send_command_async(Sock, Channel, MethodRecord, Protocol),
+ gen_server:reply(From, ok),
+ State;
handle_message({send_command_and_notify, QPid, ChPid, MethodRecord, Content},
State = #wstate{sock = Sock,
channel = Channel,