    } */

    pub fn publish(&mut self, topic: &str, message: &str) {
        debug!("Publishing");
        self._channel.basic_publish(
                types::EXCHANGE_NAME,
                topic,
                false,
                false,
                BasicProperties {