Ktor RabbitMQ plugin: install.kt modified.

ktorio · Dec 17, 2024 · bc66c08 · bc66c08
1 parent ffeafed
commit bc66c08
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 7 deletions.
diff --git a/plugins/server/io.github.damirdenis-tudor/ktor-server-rabbitmq/3.0/install.kt b/plugins/server/io.github.damirdenis-tudor/ktor-server-rabbitmq/3.0/install.kt
@@ -8,10 +8,7 @@ import io.ktor.server.application.*
 
 fun Application.install() {
     install(KabbitMQ) {
-        uri = "amqp://<user>:<password>@<address>:<port>"
-        defaultConnectionName = "<default_connection>"
-        connectionAttempts = 20
-        attemptDelay = 10
+        uri = "amqp://guest:guest@localhost:5672"
     }
 
     queueBind {
@@ -31,7 +28,7 @@ fun Application.install() {
     queueBind {
         queue = "test-queue"
         exchange = "test-exchange"
-        exchange = "test-routing-key"
+        routingKey = "test-routing-key"
         queueDeclare {
             queue = "test-queue"
             arguments = mapOf(

diff --git a/plugins/server/io.github.damirdenis-tudor/ktor-server-rabbitmq/3.0/manifest.ktor.yaml b/plugins/server/io.github.damirdenis-tudor/ktor-server-rabbitmq/3.0/manifest.ktor.yaml
@@ -1,5 +1,5 @@
-name: ktor-server-rabbitmq
-description: Adds Kafka support to your application
+name: KabbitMQ
+description: Adds RabbitMQ support to your application
 vcsLink: https://github.com/DamirDenis-Tudor/ktor-server-rabbitmq
 license: Apache 2.0