ERROR rumqtt::client::connection > Notification send failed. Error = "Full(..)"

[glennpierce]

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

[tekjar]

I'll verify and fix this today. Thanks for the report

[damody]

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);

[damody]

my bad notification_channel_capacity it's work.