hebo 0.3.3

Distributed MQTT broker
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

// Copyright (c) 2021 Xu Shaohua <shaohua@biofan.org>. All rights reserved.
// Use of this source is governed by Affero General Public License that can be found
// in the LICENSE file.

//! Backends app handlers

use codec::{v3, v5};

use super::Dispatcher;
use crate::commands::BackendsToDispatcherCmd;

impl Dispatcher {
    /// Send packet to backends.
    pub(super) async fn backends_store_packet(&mut self, _packet: &v3::PublishPacket) {}

    pub(super) async fn backends_store_packet_v5(&mut self, _packet: &v5::PublishPacket) {}

    pub(super) async fn handle_backends_cmd(&mut self, _cmd: BackendsToDispatcherCmd) {}
}