We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a0a9223 commit 3f6bc58Copy full SHA for 3f6bc58
editoast/core_client/src/mq_client.rs
@@ -180,6 +180,8 @@ pub enum MqClientError {
180
Serialization(#[educe(PartialEq(ignore))] serde_json::Error),
181
#[error("Cannot parse response status")]
182
StatusParsing,
183
+ #[error("Response channel was closed due to a delivery error")]
184
+ ResponseChannelClosed,
185
#[error("Response timeout")]
186
ResponseTimeout,
187
#[error("Connection does not exist")]
@@ -475,7 +477,8 @@ impl RabbitMQClient {
475
477
status,
476
478
})
479
}
- Ok(Err(_)) | Err(_) => Err(MqClientError::ResponseTimeout),
480
+ Ok(Err(_)) => Err(MqClientError::ResponseChannelClosed),
481
+ Err(_) => Err(MqClientError::ResponseTimeout),
482
483
484
0 commit comments