amqp 0.0.8

AMQP/RabbitMQ protocol client.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use std::convert::From;
use std::io;
use byteorder;
// use std::sync::poison::PoisonError;
// use std::sync::mutex::MutexGuard;
// use std::collections::hash::map::HashMap;

#[derive(Debug)]
pub enum AMQPError {
    AMQPIoError(io::Error),
    AMQPIoError2(byteorder::Error),
    DecodeError(&'static str),
    EncodeError,
    QueueEmpty,
    Protocol(String),
    SyncError
}

pub type AMQPResult<T> = Result<T, AMQPError>;

impl From<io::Error> for AMQPError {
    fn from(err: io::Error) -> AMQPError {
        AMQPError::AMQPIoError(err)
    }
}

impl From<byteorder::Error> for AMQPError {
    fn from(err: byteorder::Error) -> AMQPError {
        AMQPError::AMQPIoError2(err)
    }
}

//
// impl <'a, T, U> FromError<PoisonError<MutexGuard<'a, HashMap<T, U>>>> for AMQPError {
//     fn from_error(err: PoisonError<MutexGuard<'a, HashMap<T, U>>>) -> AMQPError {
//         AMQPError::SyncError
//     }
// }