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

cmake/plugins_options.cmake

@@ -11,6 +11,7 @@ option(FLB_MINIMAL "Enable minimal build configuration" No)
 
 # Inputs (sources, data collectors)
 # =================================
+DEFINE_OPTION(FLB_IN_AMQP                     "Enable AMQP input plugin"                     ON)
 DEFINE_OPTION(FLB_IN_BLOB                     "Enable Blob input plugin"                     ON)
 DEFINE_OPTION(FLB_IN_CALYPTIA_FLEET           "Enable Calyptia Fleet input plugin"           ON)
 DEFINE_OPTION(FLB_IN_COLLECTD                 "Enable Collectd input plugin"                 ON)

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)