diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-06-17 13:12:27 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-06-17 13:12:27 +0100 |
| commit | db18287dd0f59c553314a189cdc6d87d14320d1d (patch) | |
| tree | 420f51f55a5bf0a1eeb51d373dea86f09bf4a950 /src | |
| parent | 246260869c0703a6b1a98f052eeb252b9885cd27 (diff) | |
| download | rabbitmq-server-git-db18287dd0f59c553314a189cdc6d87d14320d1d.tar.gz | |
Removed unenforced redundancy in function args
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 5123ca21b7..417401be7a 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -245,10 +245,10 @@ publish(Guid, SeqId, IsPersistent, State) when is_binary(Guid) -> maybe_flush_journal(add_to_journal(SeqId, {Guid, IsPersistent}, State1)). deliver(SeqIds, State) -> - deliver_or_ack(del, ?DEL_JPREFIX, SeqIds, State). + deliver_or_ack(del, SeqIds, State). ack(SeqIds, State) -> - deliver_or_ack(ack, ?ACK_JPREFIX, SeqIds, State). + deliver_or_ack(ack, SeqIds, State). sync([], State) -> State; @@ -648,9 +648,10 @@ load_journal_entries(State = #qistate { journal_handle = Hdl }) -> _ErrOrEoF -> State end. -deliver_or_ack(_Kind, _JPrefix, [], State) -> +deliver_or_ack(_Kind, [], State) -> State; -deliver_or_ack(Kind, JPrefix, SeqIds, State) -> +deliver_or_ack(Kind, SeqIds, State) -> + JPrefix = case Kind of ack -> ?ACK_JPREFIX; del -> ?DEL_JPREFIX end, {JournalHdl, State1} = get_journal_handle(State), ok = file_handle_cache:append( JournalHdl, |