pub fn route_topic_to_bridge(&mut self, topic: &str, b_out: &str) -> anyhow::Result<()> {
        info!("setting communication topic {} -> {}", topic, b_out);
        let tx: Sender = self.take_bridge_tx(b_out)?;
        match self.routes.as_mut() {
            Some(r) => match r.get_mut(topic) {
                Some(bridges) => bridges.push(tx),
                None => {
                    r.insert(topic.to_owned(), vec![tx]);
                }
            },
            None => {
                return Err(anyhow::anyhow!(
                    "cannot change routes after orchestrator started"
                ))
            }
        };
        Ok(())
    }
/// Forward all messages received to topic to module bridge b_out
/// This method only configures route, does not spawn handler.
/// After route configuration done handler shall be started with `pipe_routes()`
/// - topic name of topic for incoming messages
/// - b_out name of outgoing bridge from Self::bridges
Forward all messages received to topic to module bridge b_out
This method only configures route, does not spawn handler.
After route configuration done handler shall be started with `pipe_routes()`
topic name of topic for incoming messages
b_out name of outgoing bridge from Self::bridges
Forward all messages received to topic to module bridge b_out This method only configures route does not spawn handler . After route configuration done handler shall be started with ` pipe_routes () ` topic name of topic for incoming messages b_out name of outgoing bridge from Self :: bridges
pub fn route_topic_to_bridge(&mut self, topic: &str, b_out: &str) -> anyhow::Result<()> {
        info!("setting communication topic {} -> {}", topic, b_out);
        let tx: Sender = self.take_bridge_tx(b_out)?;
        match self.routes.as_mut() {
            Some(r) => match r.get_mut(topic) {
                Some(bridges) => bridges.push(tx),
                None => {
                    r.insert(topic.to_owned(), vec![tx]);
                }
            },
            None => {
                return Err(anyhow::anyhow!(
                    "cannot change routes after orchestrator started"
                ))
            }
        };
        Ok(())
    }
pub fn route_topic_to_bridge ( & mut self , topic : & str , b_out : & str ) -> anyhow :: Result < ( ) > { info ! ( " " topic b_out ) ; let tx : Sender = self . take_bridge_tx ( b_out ) ? ; match self . routes . as_mut ( ) { Some ( r ) => match r . get_mut ( topic ) { Some ( bridges ) => bridges . push ( tx ) , None => { r . insert ( topic . to_owned ( ) , vec ! [ tx ] ) ; } } , None => { return Err ( anyhow :: anyhow ! ( " " ) ) } } ; Ok ( ( ) ) }
Forward all messages received to topic to module bridge b_out
This method only configures route, does not spawn handler.
Forward all messages received to topic to module bridge b_out This method only configures route does not spawn handler .
&mut self
topic
&str
b_out
&str
&mut self
topic
&str
b_out
&str