birbnetes/sample-service
4
0
Fork 0
Code Pull Requests Releases Activity

use direct exchange
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Torma Kristóf
2021-08-11 15:08:31 +02:00
parent b04ddf66c6
commit 4825f54c89
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/Application.kt
View File

@@ -51,7 +51,7 @@ fun Application.module() {
val rabbitExchangeName = appConfig.property("ktor.mq.exchange").getString() val rabbitExchangeName = appConfig.property("ktor.mq.exchange").getString()
channel.exchangeDeclare(rabbitExchangeName, BuiltinExchangeType.FANOUT) channel.exchangeDeclare(rabbitExchangeName, BuiltinExchangeType.DIRECT)
val queueName = channel.queueDeclare().queue val queueName = channel.queueDeclare().queue
channel.queueBind(queueName, rabbitExchangeName, "") channel.queueBind(queueName, rabbitExchangeName, "")