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 5b7187f commit 44d453bCopy full SHA for 44d453b
packages/rs-dapi/src/services/streaming_service/zmq_listener.rs
@@ -196,7 +196,9 @@ impl ZmqConnection {
196
"ZMQ subscription errors occured, trying to unsubscribe from successful topics",
197
);
198
199
- self.zmq_unsubscribe_all(socket).await?;
+ if let Err(unsub_err) = self.zmq_unsubscribe_all(socket).await {
200
+ debug!(error = %unsub_err, "Unsubscribe during rollback failed; preserving original subscribe error");
201
+ }
202
// return the first error
203
return Err(error);
204
};
0 commit comments