diff --git a/src/api/route/InputServiceServer.kt b/src/api/route/InputServiceServer.kt index a3b4ae3..e626c07 100644 --- 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) }