feat: implement queue system with consumer and message handling

config.php

@@ -48,5 +48,37 @@ return [
         'audience' => Env::get('JWT_AUDIENCE', 'my_audience'),
         'issuer' => Env::get('JWT_ISSUER', 'my_issuer'),
         'strict_validation' => Env::get('JWT_STRICT_VALIDATION', true, 'bool'),
+    ],
+
+    'queue' => [
+        'broker' => Env::get('QUEUE_BROKER', 'redis'),
+
+        'broker_config' => [
+
+            'redis' => [
+                'consumerGroup' => Env::get('QUEUE_REDIS_CONSUMER_GROUP', ''),
+            ],
+
+            'kafka' => [
+                'brokers' => Env::get('QUEUE_KAFKA_BROKERS', 'localhost:9092'),
+                'topic' => Env::get('QUEUE_KAFKA_TOPIC', 'my_topic'),
+            ],
+
+            'rabbitmq' => [
+                'host' => Env::get('QUEUE_RABBITMQ_HOST', 'localhost'),
+                'port' => Env::get('QUEUE_RABBITMQ_PORT', 5672, 'int'),
+                'username' => Env::get('QUEUE_RABBITMQ_USERNAME', 'guest'),
+                'password' => Env::get('QUEUE_RABBITMQ_PASSWORD', 'guest'),
+                'vhost' => Env::get('QUEUE_RABBITMQ_VHOST', '/'),
+            ],
+
+            'sqs' => [
+                'key' => Env::get('QUEUE_SQS_KEY', ''),
+                'secret' => Env::get('QUEUE_SQS_SECRET', ''),
+                'region' => Env::get('QUEUE_SQS_REGION', 'us-east-1'),
+                'version' => Env::get('QUEUE_SQS_VERSION', 'latest'),
+                'queue_url' => Env::get('QUEUE_SQS_QUEUE_URL', ''),
+            ]
+        ]
     ]
 ];