None MessageResult, producer panic

[51yu]

producer panic if message result is None ..
https://github.com/rabbitmq/rabbitmq-stream-rust-client/blob/main/src/producer.rs#L556

it happen few minutes after app run, and app exit with panic
how to handle it gracefully without app panic ?

[wolf4ood]

Hi @51yu

thanks for raising this. So the basic step to reproduce it is to setup a producer and after few minutes it should panic right?

[51yu]

stacktrace

thread 'tokio-runtime-worker' panicked at 'not yet implemented', /rabbitmq-stream-client-0.1.0/src/producer.rs:558:21

<rabbitmq_stream_client::client::Client as rabbitmq_stream_client::client::handler::MessageHandler>::handle_message::{{closure}}::{{closure}}
             at rabbitmq-stream-client-0.1.0/src/client/mod.rs:100:81

[51yu]

Hi @51yu

thanks for raising this. So the basic step to reproduce it is to setup a producer and after few minutes it should panic right?

yes

[wolf4ood]

Hi @51yu

I think the main issue is the heartbeat handling which is still missing,
There where a PR in draft i can pick it from there and finish the work ASAP

Thanks

[51yu]

Meanwhile, could we mitigate the issue by letting producer periodically publish dummy message to stream and let consumer ignore that ? - convince broker, producer is still alive

[wolf4ood]

The best workaround it would be to disable the heartbeat, but from client side it's is not exposed yet. I would wait for this fix, I think it could be available tomorrow :)

[wolf4ood]

@51yu

I've opened the PR Waiting for the review and then it should fix this issue

Thanks