Crate amqpr_api [] [src]

amqpr-api is AMQP client api library. You can talk with AMQP server via channel controller provided by this crate. There is two kind of channel controllers; GlobalChannelController and LocalChannelController.

Reexports

pub use handshake::start_handshake;
pub use channel::open_channel;
pub use exchange::declare_exchange;
pub use queue::declare_queue;
pub use queue::bind_queue;
pub use basic::publish;
pub use basic::get_delivered;
pub use basic::start_consume;
pub use subscribe_stream::subscribe_stream;
pub use publish_sink::publish_sink;

Modules

basic
channel
errors
exchange
handshake
publish_sink

Convenient module to publish item.

queue
subscribe_stream

Convenient module to subscribe item.

Structs

AmqpSocket
InOut

This struct is useful when the case such as some functions require S: Stream + Sink but your socket is separeted into Stream and Sink.