danderson/ofborg
0
0
Fork 0
forked from the-distro/ofborg
Code Pull requests Activity

remove glob imports in easylapin

Browse source
This commit is contained in:
Daiderd Jordan 2020-04-30 00:11:05 +02:00
parent fb8b4249f1
commit 5b8d7e079a
No known key found for this signature in database
GPG key ID: D02435D05B810C96
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
ofborg/src/easylapin.rs
View file

@ -1,7 +1,10 @@
use std::pin::Pin; use std::pin::Pin;
use crate::config::RabbitMQConfig; use crate::config::RabbitMQConfig;
use crate::easyamqp::*; use crate::easyamqp::{
BindQueueConfig, ChannelExt, ConsumeConfig, ConsumerExt, ExchangeConfig, ExchangeType,
QueueConfig,
};
use crate::notifyworker::{NotificationReceiver, SimpleNotifyWorker}; use crate::notifyworker::{NotificationReceiver, SimpleNotifyWorker};
use crate::ofborg; use crate::ofborg;
use crate::worker::{Action, SimpleWorker}; use crate::worker::{Action, SimpleWorker};
@ -9,9 +12,14 @@ use crate::worker::{Action, SimpleWorker};
use async_std::future::Future; use async_std::future::Future;
use async_std::stream::StreamExt; use async_std::stream::StreamExt;
use async_std::task; use async_std::task;
use lapin::message::Delivery;
use lapin::options::{
BasicAckOptions, BasicConsumeOptions, BasicNackOptions, BasicPublishOptions,
ExchangeDeclareOptions, QueueBindOptions, QueueDeclareOptions,
};
use lapin::types::{AMQPValue, FieldTable};
use lapin::{ use lapin::{
message::Delivery, options::*, types::AMQPValue, types::FieldTable, BasicProperties, Channel, BasicProperties, Channel, CloseOnDrop, Connection, ConnectionProperties, ExchangeKind,
CloseOnDrop, Connection, ConnectionProperties, ExchangeKind,
}; };
pub fn from_config(cfg: &RabbitMQConfig) -> Result<CloseOnDrop<Connection>, lapin::Error> { pub fn from_config(cfg: &RabbitMQConfig) -> Result<CloseOnDrop<Connection>, lapin::Error> {