Crate amqpr_api

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.

Re-exports

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::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

Connection 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.