composer update

composer.json

@@ -2,6 +2,7 @@
   "name": "tm_xls/rocket-mq-client-thinkphp",
   "description": "rocket-mq-thinkphp 适配客户端",
   "license": "proprietary",
+  "type": "tm_xls_rocket_mq",
   "authors": [
     {
       "name": "zyimm",

src/consumer/contract/ListenerInterface.php

@@ -5,4 +5,6 @@ namespace tm\xls\rocketMq\thinkphp\consumer\contract;
 interface ListenerInterface
 {
     public function handle();
+
+    public function enable();
 }

src/route.php

@@ -7,14 +7,13 @@ use function React\Async\coroutine;
 $path = config('rocket_mq.callback', '/rocketmq/producer/notify');
 //注册回调路由
 Route::post($path, function () {
-    $promise = coroutine(function () {
+    coroutine(function () {
         app()->make(Consumer::class, [
             request()->param()
         ])->distribute();
-    });
+    })->then(function () {
-    $promise->then(function () {
+        echo 'success';
-        return 'success';
     },function (){
-        return 'error';
+        echo 'error';
     });
 });