in_amqp: Initial implementation for in_amqp plugin

Signed-off-by: Matwey V. Kornilov <matwey.kornilov@gmail.com>

Author: matwey

CMakeLists.txt

@@ -1332,6 +1332,14 @@ if (FLB_IN_EBPF)
 
 endif()
 
+# AMQP
+# ==========
+find_package(rabbitmq-c)
+if(FLB_IN_AMQP AND (NOT rabbitmq-c_FOUND))
+  message(STATUS "rabbitmq-c is not found. Disabling AMQP support.")
+  FLB_OPTION(FLB_IN_AMQP OFF)
+endif()
+
 # Pthread Local Storage
 # =====================
 # By default we expect the compiler already support thread local storage

plugins/CMakeLists.txt

@@ -340,6 +340,7 @@ REGISTER_IN_PLUGIN("in_mqtt")
 REGISTER_IN_PLUGIN("in_lib")
 REGISTER_IN_PLUGIN("in_forward")
 REGISTER_IN_PLUGIN("in_random")
+REGISTER_IN_PLUGIN("in_amqp")
 
 # PROCESSORS
 # ==========

plugins/in_amqp/CMakeLists.txt

@@ -0,0 +1,4 @@
+set(src
+  in_amqp.c)
+
+FLB_PLUGIN(in_amqp "${src}" rabbitmq::rabbitmq)