how to use mpsc::channel to dispatch msg when handle incoming publishes and how to subscribe to multiple topics in one API call? about ntex-mqtt HOT 3 CLOSED

1. you just call topic_filter multiple time, sink.subscribe().topic_filter(“topic1”).topic_filter(“topic2”) etc
2. post compilation error, you may need to do something like fn_service(move |…

btw this is for discussions rather than issues

from ntex-mqtt.

1. you just call topic_filter multiple time, sink.subscribe().topic_filter(“topic1”).topic_filter(“topic2”) etc
2. post compilation error, you may need to do something like fn_service(move |…

btw this is for discussions rather than issues

Thank you!!! yes, the fn_service(move | works. One more question:

The publish.ack(Success) consumes the entire publish but indeed it only needs the packet_id. I have to copy topic and payload when I want to send the content out.

Is there an API like: pub fn ack(&self, reason_code: codec::PublishAckReason) -> ControlResult which doesn't need the entire publish to create a control message? The current API is: pub fn ack(self, reason_code: codec::PublishAckReason) -> ControlResult.

v5::client::ControlMessage::Publish(publish) => {
                log::info!(
                    "incoming publish: {:?} -> {:?} payload {:?}",
                    publish.packet().packet_id,
                    publish.packet().topic,
                    publish.packet().payload
                );
                let res = publish.ack(v5::codec::PublishAckReason::Success); // the publish is consumed here.
                if let Err(e) = tx.send(publish) { //can't send it anymore.
                    log::error!("Error sending publish: {:?}", e);
                }

                Ready::Ok(res)
            }

from ntex-mqtt.

close and move to discussion.

from ntex-mqtt.