Module amqpr_api::subscribe_stream

Convenient module to subscribe item.

Reexports

pub use basic::consume::StartConsumeOption;

Enums

SubscribeStream

Stream of subscribed item from AMQP server. This stream is based on no_ack consume because of performance. But that may cause decreasing of reliability. If you want reliability rather than performance, you should use subscribe_stream_ack function (after we implement that...).

Functions

subscribe_stream

Returns SubscribeStream which is Stream of DeliveredItem. Basically, this function send Consume message to AMQO server first, and then wait for each items. This uses get_delivered method internally. If you want to know more detail please have a look at get_delivered function document.