Open glennpierce opened 5 years ago
I'll verify and fix this today. Thanks for the report
I change notification_channel_capacity from mqtt_option is useless. but I change src to 10000. it's work. wtf?
pub fn run(mqttoptions: MqttOptions) -> Result<UserHandle, ConnectError> {
let (notification_tx, notification_rx) = crossbeam_channel::bounded(10000);
let (request_tx, request_rx) = mpsc::channel::<Request>(mqttoptions.request_channel_capacity());
let (command_tx, command_rx) = mpsc::channel::<Command>(5);
my bad notification_channel_capacity it's work.
I have some simple code that subscribes to two mqtt messages which arrive around every couple of seconds and every 8 seconds publishes. However, every couple of days or so I start getting the error
ERROR rumqtt::client::connection > Notification send failed. Error = "Full(..)"
Does this come from the client or the mqtt server (mosquito) ? How can I handle this error ?
I am just using the default branch. ie
rumqtt = "*"
Thanks