do not declare queue

2020-05-22 03:26:39 +02:00
parent 7f14051429
commit 63f7865f7c
1 changed files with 1 additions and 3 deletions
--- a/src/api/route/InputServiceServer.kt
+++ b/src/api/route/InputServiceServer.kt
@@ -56,8 +56,6 @@ class InputServiceServer {
        val rabbitExchangeName = appConfig.property("ktor.mq.exchange").getString()

        channel.exchangeDeclare(rabbitExchangeName, BuiltinExchangeType.FANOUT)
-        val queueName = channel.queueDeclare().queue
-        channel.queueBind(queueName, rabbitExchangeName, "")

        val gson = GsonBuilder().setPrettyPrinting().create()

@@ -98,7 +96,7 @@ class InputServiceServer {
                resultObjectService.addOne(currentApiObject)
            }

-            channel.basicPublish("",queueName, null, tag.toString().toByteArray())
+            channel.basicPublish(rabbitExchangeName,"" , null, tag.toString().toByteArray())

            call.respond(currentApiObject)
        }