Skip to content

Commit e6882e2

Browse files
committed
Do conversion once
1 parent 20d04d9 commit e6882e2

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/NServiceBus.Transport.RabbitMQ/Receiving/MessagePump.cs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -209,6 +209,7 @@ async Task Process(BasicDeliverEventArgs message)
209209
var processed = false;
210210
var errorHandled = false;
211211
var numberOfDeliveryAttempts = 0;
212+
var messageBody = message.Body.ToArray();
212213

213214
while (!processed && !errorHandled)
214215
{
@@ -217,7 +218,7 @@ async Task Process(BasicDeliverEventArgs message)
217218
var contextBag = new ContextBag();
218219
contextBag.Set(message);
219220

220-
var messageContext = new MessageContext(messageId, headers, message.Body.ToArray() ?? Array.Empty<byte>(), transportTransaction, tokenSource, contextBag);
221+
var messageContext = new MessageContext(messageId, headers, messageBody ?? Array.Empty<byte>(), transportTransaction, tokenSource, contextBag);
221222

222223
await onMessage(messageContext).ConfigureAwait(false);
223224
processed = true;
@@ -229,7 +230,7 @@ async Task Process(BasicDeliverEventArgs message)
229230
var contextBag = new ContextBag();
230231
contextBag.Set(message);
231232

232-
var errorContext = new ErrorContext(exception, headers, messageId, message.Body.ToArray() ?? Array.Empty<byte>(), transportTransaction, numberOfDeliveryAttempts, contextBag);
233+
var errorContext = new ErrorContext(exception, headers, messageId, messageBody ?? Array.Empty<byte>(), transportTransaction, numberOfDeliveryAttempts, contextBag);
233234

234235
try
235236
{

0 commit comments

Comments
 (0)