Hands-On Microservices with Rust

Crate

Add the following imports to the src/lib.rs source file:

pub mod queue_actor; use actix::{Message, SystemRunner};use failure::Error;use futures::Future;use lapin::channel::{Channel, QueueDeclareOptions};use lapin::client::{Client, ConnectionOptions};use lapin::error::Error as LapinError;use lapin::queue::Queue;use lapin::types::FieldTable;use serde_derive::{Deserialize, Serialize};use tokio::net::TcpStream;

You are familiar with some types. Let's discuss some of the new ones. Client represents a client that connects to RabbitMQ. The Channel type will be created as a result of a connection and is returned by a Client. QueueDeclareOptions is used as a parameter for the queue_declare method call of a Channel. ConnectionOptions is necessary ...