diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-21 15:29:45 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-21 15:29:45 +0100 |
| commit | 4a84bd9d7908931bbe7ce22e7f24129b66e6e7f7 (patch) | |
| tree | ea340d1fcf13e64b1beb4899fdb17d7bc4dece53 | |
| parent | 993fd4a1ed29412237886b511830d508e10fdd0e (diff) | |
| download | rabbitmq-server-4a84bd9d7908931bbe7ce22e7f24129b66e6e7f7.tar.gz | |
Cosmetic
| -rw-r--r-- | src/rabbit_invariable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_invariable_queue.erl b/src/rabbit_invariable_queue.erl index bc58cc8c..ad01d8f7 100644 --- a/src/rabbit_invariable_queue.erl +++ b/src/rabbit_invariable_queue.erl @@ -137,7 +137,7 @@ fetch(AckRequired, State = #iv_state { queue = Q }) -> fetch_internal(AckRequired, Q1, Msg, MsgProps, IsDelivered, State). fetch_internal(AckRequired, Q1, - Msg = #basic_message {guid = Guid}, + Msg = #basic_message { guid = Guid }, MsgProps, IsDelivered, State = #iv_state { len = Len, qname = QName, @@ -161,7 +161,7 @@ ack(AckTags, State = #iv_state { qname = QName, durable = IsDurable, PA1 = remove_acks(AckTags, PA), State #iv_state { pending_ack = PA1 }. -tx_publish(Txn, Msg, MsgProps, State = #iv_state { qname = QName, +tx_publish(Txn, Msg, MsgProps, State = #iv_state { qname = QName, durable = IsDurable }) -> Tx = #tx { pending_messages = Pubs } = lookup_tx(Txn), store_tx(Txn, Tx #tx { pending_messages = [{Msg, MsgProps} | Pubs] }), |