Hands-On Microservices with Rust

Dependencies

To create an actor, we need the following dependencies:

use super::{ensure_queue, spawn_client};use actix::fut::wrap_future;use actix::{Actor, Addr, AsyncContext, Context, Handler, Message, StreamHandler, SystemRunner};use failure::{format_err, Error};use futures::Future;use lapin::channel::{BasicConsumeOptions, BasicProperties, BasicPublishOptions, Channel};use lapin::error::Error as LapinError;use lapin::message::Delivery;use lapin::types::{FieldTable, ShortString};use log::{debug, warn};use serde::{Deserialize, Serialize};use tokio::net::TcpStream;use uuid::Uuid;pub type TaskId = ShortString;

First, we use the ensure_queue function from the super module, which creates a new queue, but we will implement it later in this chapter. ...