Skip to content

Commit

Permalink
Use isolated dispatch for control message to prevent attaching to out…
Browse files Browse the repository at this point in the history
…box's transaction scope if transport supports transaction scopes
  • Loading branch information
SzymonPobiega committed Jan 10, 2025
1 parent 006097b commit b4c409f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ async Task DispatchControlMessage(CancellationToken cancellationToken)
}
}
var message = new OutgoingMessage(SessionId, headers, ReadOnlyMemory<byte>.Empty);
var outgoingMessages = new TransportOperations(new TransportTransportOperation(message, new UnicastAddressTag(physicalQueueAddress)));
var outgoingMessages = new TransportOperations(new TransportTransportOperation(message, new UnicastAddressTag(physicalQueueAddress), null, DispatchConsistency.Isolated));
await dispatcher.Dispatch(outgoingMessages, new TransportTransaction(), cancellationToken).ConfigureAwait(false);
}

Expand Down

0 comments on commit b4c409f

Please sign in to comment.