vector/sinks/amqp/
mod.rs

1//! `AMQP` sink.
2//! Handles version AMQP 0.9.1 which is used by RabbitMQ.
3mod channel;
4mod config;
5mod encoder;
6mod request_builder;
7mod service;
8mod sink;
9
10#[cfg(all(test, feature = "amqp-integration-tests"))]
11mod integration_tests;
12
13pub use config::AmqpSinkConfig;
14use snafu::Snafu;
15
16#[derive(Debug, Snafu)]
17enum BuildError {
18    #[snafu(display("creating amqp producer failed: {}", source))]
19    AmqpCreateFailed { source: vector_common::Error },
20}