added simple rabbitmq compatibility

app/Events/ExampleEvent.php

@@ -9,8 +9,11 @@ class ExampleEvent extends Event
      *
      * @return void
      */
-    public function __construct()
+
+    public $message;
+    
+    public function __construct(string $message)
     {
-        //
+        $this->message = $message;
     }
 }

app/Http/Controllers/CustomerController.php

@@ -19,6 +19,8 @@ use App\AbstractCustomer;
 use App\PrivateCustomer;
 use App\BusinessCustomer;
 
+use App\Events\ExampleEvent;
+
 class CustomerController extends Controller{
 
     use Features;
@@ -33,7 +35,9 @@ class CustomerController extends Controller{
     }
 
     public function show(Request $request){
-
+        $msg = "Nachricht an RabbitMQ Queue und zurück";
+        event(new ExampleEvent($msg));
+        return response()->json(['test' => 'test']);
         try{
             $repository = $this->em->getRepository(AbstractCustomer::class);
         }

app/Listeners/ExampleListener.php

@@ -26,6 +26,24 @@ class ExampleListener
      */
     public function handle(ExampleEvent $event)
     {
-        //
+        $msg = $event->message;
+        for($i=0; $i<500; ++$i){
+
+            \Amqp::publish('holz', $msg);
+
+        }
+        \Amqp::consume('direct_queue', function ($message, $resolver) {
+    		
+            \Log::info($message->body);
+         
+            $resolver->acknowledge($message);
+         
+            $resolver->stopWhenProcessed();
+                 
+         });
+
+        \Log::info('FERTIG');
+
+
     }
 }

bootstrap/app.php

@@ -22,7 +22,6 @@ $app = new Laravel\Lumen\Application(
 );
 
 $app->withFacades();
-
 //$app->withEloquent();
 
 /*
@@ -84,16 +83,19 @@ $app->middleware([
 | totally optional, so you are not required to uncomment this line.
 |
 */
+$app->configure('amqp');
+$app->register(Bschmitt\Amqp\LumenServiceProvider::class);
 
 $app->register(LaravelDoctrine\ORM\DoctrineServiceProvider::class);
 $app->register(LaravelDoctrine\Migrations\MigrationsServiceProvider::class);
 // $app->register(App\Providers\AppServiceProvider::class);
 // $app->register(App\Providers\AuthServiceProvider::class);
-// $app->register(App\Providers\EventServiceProvider::class);
-
+$app->register(App\Providers\EventServiceProvider::class);
+//$app->register(VladimirYuldashev\LaravelQueueRabbitMQ\LaravelQueueRabbitMQServiceProvider::class);
 //class_alias('LaravelDoctrine\ORM\Facades\EntityManager', 'EntityManager');
 //class_alias('LaravelDoctrine\ORM\Facades\Registry', 'Registry');
 //class_alias('LaravelDoctrine\ORM\Facades\Doctrine', 'Doctrine');
+class_alias(\Illuminate\Support\Facades\App::class, 'App');
 
 /*
 |--------------------------------------------------------------------------

composer.json

@@ -6,6 +6,7 @@
     "type": "project",
     "require": {
         "php": ">=7.1.3",
+        "bschmitt/laravel-amqp": "^2.0",
         "firebase/php-jwt": "^5.0",
         "laravel-doctrine/extensions": "^1.0",
         "laravel-doctrine/migrations": "^1.2",

robin-rabbitmq-test @ 6d11daa9

-Subproject commit 6d11daa9a3f7221f6b2446b1fe9250b017039ba3