diff options
| author | Antoine A <> | 2024-03-22 16:18:30 +0100 |
|---|---|---|
| committer | Antoine A <> | 2024-03-22 16:18:30 +0100 |
| commit | 7d23c382fbdd6b99f6d80a2ff9e725ffdfa580ef (patch) | |
| tree | f46a9c6f77d040728252642c9d95e1847e6f29e5 /bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt | |
| parent | e185af0f365fbcbed2627b33f1552baf30057a34 (diff) | |
| download | libeufin-7d23c382fbdd6b99f6d80a2ff9e725ffdfa580ef.tar.gz libeufin-7d23c382fbdd6b99f6d80a2ff9e725ffdfa580ef.tar.bz2 libeufin-7d23c382fbdd6b99f6d80a2ff9e725ffdfa580ef.zip | |
Add migration test and improve SQL drop script
Diffstat (limited to 'bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt')
| -rw-r--r-- | bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt b/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt index eb95e2c4..cd64e77f 100644 --- a/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt +++ b/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt @@ -52,7 +52,7 @@ internal class NotificationWatcher(private val pgSource: PGSimpleDataSource) { runBlocking { while (true) { try { - val conn = pgSource.pgConnection() + val conn = pgSource.pgConnection("libeufin_bank") // Listen to all notifications channels conn.execSQLUpdate("LISTEN bank_tx") |