diff --git a/src/channel.rs b/src/channel.rs index 31da7ef..882fe2b 100644 --- a/src/channel.rs +++ b/src/channel.rs @@ -348,6 +348,14 @@ impl<'a> Basic<'a> for Channel { -> AMQPResult<()> where S: Into { + if mandatory { + warn!("basic_publish(mandatory=true) failures are not handled and result in blocked channels!"); + } + + if immediate { + warn!("basic_publish(immediate=true) failures are not handled and result in blocked channels!"); + } + let publish = &Publish { ticket: 0, exchange: exchange.into(),