diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index f518c561fe..25859c22f9 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -488,11 +488,10 @@ attempt_delivery(#delivery{txn = none, %% we don't need an expiry here because messages are %% not being enqueued, so we use an empty %% message_properties. - BP = ?BASE_MESSAGE_PROPERTIES, {AckTag, BQS1} = BQ:publish_delivered( AckRequired, Message, - BP#message_properties{ + (?BASE_MESSAGE_PROPERTIES)#message_properties{ needs_confirming = NeedsConfirming}, BQS), {{Message, false, AckTag}, true, |