feat(new sink): Initial rabbitmq sink implementation

.circleci/config.yml

@@ -113,6 +113,7 @@ jobs:
           - xpack.ssl.certificate=certs/localhost.crt
           - xpack.ssl.key=certs/localhost.key
       - image: yandex/clickhouse-server:19
+      - image: rabbitmq:alpine
     steps:
       - checkout
       - setup_remote_docker:
@@ -578,7 +579,6 @@ require-tests-checks-and-verifications: &require-tests-checks-and-verifications
     - verify-rpm-artifact-on-centos-7
     - verify-systemd-on-debian
 
-
 #
 # Workflows
 #

Cargo.toml

@@ -127,6 +127,7 @@ base64 = "0.10.1"
 shiplift = { git = "https://github.com/LucioFranco/shiplift", branch = "timber" }
 owning_ref = "0.4.0"
 listenfd = "0.3.3"
+lapin-futures = "0.28.0"
 
 [build-dependencies]
 prost-build = "0.4.0"
@@ -157,7 +158,8 @@ docker = [
   "kinesis-integration-tests",
   "s3-integration-tests",
   "splunk-integration-tests",
-  "docker-integration-tests"
+  "docker-integration-tests",
+  "rabbitmq-integration-tests"
 ]
 cloudwatch-logs-integration-tests = []
 cloudwatch-metrics-integration-tests = []
@@ -168,6 +170,7 @@ kinesis-integration-tests = []
 s3-integration-tests = []
 splunk-integration-tests = []
 docker-integration-tests = []
+rabbitmq-integration-tests = []
 
 [[bench]]
 name = "bench"

docker-compose.yml

@@ -74,3 +74,7 @@ services:
       image: yandex/clickhouse-server:19
       ports:
         - "8123:8123"
+    rabbitmq:
+      image: rabbitmq:alpine
+      ports:
+        - "5672:5672"

src/sinks/mod.rs

@@ -15,6 +15,7 @@ pub mod http;
 #[cfg(feature = "rdkafka")]
 pub mod kafka;
 pub mod prometheus;
+pub mod rabbitmq;
 pub mod splunk_hec;
 pub mod statsd;
 pub mod tcp;