@@ -42,7 +42,11 @@ public class PublishException : RabbitMQClientException
42
42
private bool _isReturn = false ;
43
43
private ulong _publishSequenceNumber = ulong . MinValue ;
44
44
45
- public PublishException ( ulong publishSequenceNumber , bool isReturn ) : base ( )
45
+ public PublishException ( ulong publishSequenceNumber , bool isReturn ) : this ( publishSequenceNumber , isReturn , "Message rejected by broker." )
46
+ {
47
+ }
48
+
49
+ public PublishException ( ulong publishSequenceNumber , bool isReturn , string message ) : base ( message )
46
50
{
47
51
if ( publishSequenceNumber == ulong . MinValue )
48
52
{
@@ -76,10 +80,10 @@ public class PublishReturnException : PublishException
76
80
private readonly ushort _replyCode ;
77
81
private readonly string _replyText ;
78
82
79
- public PublishReturnException ( ulong publishSequenceNumber ,
83
+ public PublishReturnException ( ulong publishSequenceNumber , string message ,
80
84
string ? exchange = null , string ? routingKey = null ,
81
85
ushort ? replyCode = null , string ? replyText = null )
82
- : base ( publishSequenceNumber , true )
86
+ : base ( publishSequenceNumber , true , message )
83
87
{
84
88
_exchange = exchange ?? string . Empty ;
85
89
_routingKey = routingKey ?? string . Empty ;
@@ -116,7 +120,8 @@ internal static PublishException Create(bool isReturn,
116
120
{
117
121
if ( isReturn )
118
122
{
119
- return new PublishReturnException ( deliveryTag , exchange , routingKey , replyCode , replyText ) ;
123
+ string message = $ "{ replyCode } { replyText } Exchange: { exchange } Routing Key: { routingKey } ";
124
+ return new PublishReturnException ( deliveryTag , message , exchange , routingKey , replyCode , replyText ) ;
120
125
}
121
126
else
122
127
{
0 commit comments