File 0025-turtle_subscriber-shrink-handle_message-5.patch of Package turtle
From be0710d12c48f2f4d3159fbacd828c819af20804 Mon Sep 17 00:00:00 2001
From: Led <ledest@gmail.com>
Date: Wed, 28 Nov 2018 18:58:56 +0200
Subject: [PATCH] turtle_subscriber: shrink handle_message/5
---
src/turtle_subscriber.erl | 14 ++++----------
1 file changed, 4 insertions(+), 10 deletions(-)
diff --git a/src/turtle_subscriber.erl b/src/turtle_subscriber.erl
index 2f9d5e5..a83e7a0 100644
--- a/src/turtle_subscriber.erl
+++ b/src/turtle_subscriber.erl
@@ -269,20 +269,14 @@ handle_message(Tag, Key,
end,
case Res of
%% Bulk messages
- L when is_list(L) -> {L, IState};
+ _ when is_list(Res) -> {Res, IState};
{L, _} when is_list(L) -> Res;
%% Single messages
- ack -> {ack, IState};
- {ack, _} -> Res;
+ _ when Res =:= ack; Res =:= reject; Res =:= remove; Res =:= ok -> {Res, IState};
+ {T, _} when T =:= ack; T =:= reject; T =:= remove; T =:= ok -> Res;
{reply, CType, Msg} -> {reply, CType, Msg, IState};
{reply, _, _, _} -> Res;
- reject -> {reject, IState};
- {reject, _} -> Res;
- remove -> {remove, IState};
- {remove, _} -> Res;
- {stop, _, _} -> Res;
- {ok, _} -> Res;
- ok -> {ok, IState}
+ {stop, _, _} -> Res
end.
format_amqp_msg(#amqp_msg { payload = Payload, props = Props }) when byte_size(Payload) =< 64 ->
--
2.16.4