Ver Fonte

MQ -> RABBITMQ

visuddhinanda há 2 anos atrás
pai
commit
170174b22e

+ 1 - 1
app/Console/Commands/MqDiscussion.php

@@ -40,7 +40,7 @@ class MqDiscussion extends Command
      */
     public function handle()
     {
-		$connection = new AMQPStreamConnection(env("MQ_HOST"), env("MQ_PORT"), env("MQ_USERNAME"), env("MQ_PASSWORD"));
+		$connection = new AMQPStreamConnection(env("RABBITMQ_HOST"), env("RABBITMQ_PORT"), env("RABBITMQ_USERNAME"), env("RABBITMQ_PASSWORD"));
 		$channel = $connection->channel();
 
 		$channel->queue_declare('discussion', false, true, false, false);

+ 1 - 1
app/Console/Commands/MqPr.php

@@ -40,7 +40,7 @@ class MqPr extends Command
      */
     public function handle()
     {
-		$connection = new AMQPStreamConnection(env("MQ_HOST"), env("MQ_PORT"), env("MQ_USERNAME"), env("MQ_PASSWORD"));
+		$connection = new AMQPStreamConnection(env("RABBITMQ_HOST"), env("RABBITMQ_PORT"), env("RABBITMQ_USERNAME"), env("RABBITMQ_PASSWORD"));
 		$channel = $connection->channel();
 
 		$channel->queue_declare('suggestion', false, true, false, false);

+ 1 - 1
app/Console/Commands/MqProgress.php

@@ -38,7 +38,7 @@ class MqProgress extends Command
      */
     public function handle()
     {
-		$connection = new AMQPStreamConnection(env("MQ_HOST"), env("MQ_PORT"), env("MQ_USERNAME"), env("MQ_PASSWORD"));
+		$connection = new AMQPStreamConnection(env("RABBITMQ_HOST"), env("RABBITMQ_PORT"), env("RABBITMQ_USERNAME"), env("RABBITMQ_PASSWORD"));
 		$channel = $connection->channel();
 
 		$channel->queue_declare('progress', false, true, false, false);

+ 1 - 1
app/Console/Commands/MqWbwAnalyses.php

@@ -38,7 +38,7 @@ class MqWbwAnalyses extends Command
      */
     public function handle()
     {
-		$connection = new AMQPStreamConnection(env("MQ_HOST"), env("MQ_PORT"), env("MQ_USERNAME"), env("MQ_PASSWORD"));
+		$connection = new AMQPStreamConnection(env("RABBITMQ_HOST"), env("RABBITMQ_PORT"), env("RABBITMQ_USERNAME"), env("RABBITMQ_PASSWORD"));
 		$channel = $connection->channel();
 
 		$channel->queue_declare('wbw-analyses', false, true, false, false);

+ 9 - 1
app/Console/Commands/TestMdRender.php

@@ -90,6 +90,14 @@ class TestMdRender extends Command
         content=# ddd}}
         md;
 
+        $data['article'] = <<<md
+        {{article|
+        type=article|
+        id=27ade9ad-2d0c-4f66-b857-e9335252cc08|
+        title=第一章 戒律概说(Vinaya)|
+        style=modal}}
+        md;
+
         //$wiki = MdRender::markdown2wiki($data['noteMulti']);
         //$xml = MdRender::wiki2xml($wiki,['00ae2c48-c204-4082-ae79-79ba2740d506']);
         //$this->info($xml);
@@ -98,7 +106,7 @@ class TestMdRender extends Command
         //$html = MdRender::xmlQueryId($xml, "1");
         //$sent = MdRender::take_sentence($html);
         //print_r($sent);
-        echo MdRender::render2($data['noteMulti'],['00ae2c48-c204-4082-ae79-79ba2740d506'],null,'read','translation');
+        echo MdRender::render2($data['article'],['00ae2c48-c204-4082-ae79-79ba2740d506'],null,'read','translation');
         return 0;
     }
 }

+ 1 - 1
app/Console/Commands/TestMqWorker.php

@@ -39,7 +39,7 @@ class TestMqWorker extends Command
      */
     public function handle()
     {
-		$connection = new AMQPStreamConnection(env("MQ_HOST"), env("MQ_PORT"), env("MQ_USERNAME"), env("MQ_PASSWORD"));
+		$connection = new AMQPStreamConnection(env("RABBITMQ_HOST"), env("RABBITMQ_PORT"), env("RABBITMQ_USERNAME"), env("RABBITMQ_PASSWORD"));
 		$channel = $connection->channel();
 
 		$channel->queue_declare('hello', false, true, false, false);

+ 1 - 1
app/Http/Api/Mq.php

@@ -5,7 +5,7 @@ use PhpAmqpLib\Message\AMQPMessage;
 class Mq{
     public static function publish(string $channelName, $message){
                 //一对一
-		$connection = new AMQPStreamConnection(env("MQ_HOST"), env("MQ_PORT"), env("MQ_USERNAME"), env("MQ_PASSWORD"));
+		$connection = new AMQPStreamConnection(env("RABBITMQ_HOST"), env("RABBITMQ_PORT"), env("RABBITMQ_USERNAME"), env("RABBITMQ_PASSWORD"));
 		$channel = $connection->channel();
 		$channel->queue_declare($channelName, false, true, false, false);