@@ -42,7 +42,7 @@ public class PublishException : RabbitMQClientException
4242 private bool _isReturn = false ;
4343 private ulong _publishSequenceNumber = ulong . MinValue ;
4444
45- public PublishException ( ulong publishSequenceNumber , bool isReturn ) : base ( )
45+ public PublishException ( ulong publishSequenceNumber , bool isReturn , string message ) : base ( message )
4646 {
4747 if ( publishSequenceNumber == ulong . MinValue )
4848 {
@@ -76,10 +76,10 @@ public class PublishReturnException : PublishException
7676 private readonly ushort _replyCode ;
7777 private readonly string _replyText ;
7878
79- public PublishReturnException ( ulong publishSequenceNumber ,
79+ public PublishReturnException ( ulong publishSequenceNumber , string message ,
8080 string ? exchange = null , string ? routingKey = null ,
8181 ushort ? replyCode = null , string ? replyText = null )
82- : base ( publishSequenceNumber , true )
82+ : base ( publishSequenceNumber , true , message )
8383 {
8484 _exchange = exchange ?? string . Empty ;
8585 _routingKey = routingKey ?? string . Empty ;
@@ -116,11 +116,13 @@ internal static PublishException Create(bool isReturn,
116116 {
117117 if ( isReturn )
118118 {
119- return new PublishReturnException ( deliveryTag , exchange , routingKey , replyCode , replyText ) ;
119+ string message = $ "{ replyCode } { replyText } Exchange: { exchange } Routing Key: { routingKey } ";
120+ return new PublishReturnException ( deliveryTag , message , exchange , routingKey , replyCode , replyText ) ;
120121 }
121122 else
122123 {
123- return new PublishException ( deliveryTag , isReturn ) ;
124+ string message = "Message rejected by broker." ;
125+ return new PublishException ( deliveryTag , isReturn , message ) ;
124126 }
125127 }
126128 }
0 commit comments