Skip to content

Commit 1404aa7

Browse files
committed
Fix: enhance ProducerClosedException with detailed error information on link closure
1 parent 5d2f2db commit 1404aa7

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

src/ArtemisNetClient/ProducerBase.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,10 @@ private static void OnOutcome(ILink sender, Amqp.Message message, Outcome outcom
5959
}
6060
else if (link.IsDetaching() || link.IsClosed)
6161
{
62-
tcs.TrySetException(new ProducerClosedException());
62+
var error = link.Error;
63+
tcs.TrySetException(error != null
64+
? new ProducerClosedException(error.Description, error.Condition, null)
65+
: new ProducerClosedException());
6366
}
6467
else if (outcome.Descriptor.Code == MessageOutcomes.Rejected.Descriptor.Code)
6568
{

0 commit comments

Comments
 (0)