【发布时间】:2022-01-02 20:31:47
【问题描述】:
我正在尝试在 Kotlin Vert.x 应用程序中实现 Postgres pub/sub,但它似乎不起作用。 这是我尝试过的:
public override suspend fun start() {
val subscriber = PgSubscriber.subscriber(
Vertx.vertx(), PgConnectOptions()
.setPort(5432)
.setDatabase("postgres")
.setHost("localhost")
.setUser("postgres")
)
val connect = subscriber.connect { ar: AsyncResult<Void?> ->
if (ar.succeeded())
println(ar.result())
subscriber.channel("added_workspace_request")
.handler { payload: String -> println("Received $payload") }
}
}
}```
【问题讨论】:
-
更清楚一点,什么不工作提供错误日志总是有用的
标签: postgresql kotlin vert.x