Skip to content

Commit b4ca67f

Browse files
author
Shaun Hubbard
committedApr 25, 2018
fixed potential issue with case insensivitiy, @MrMage brought it to my attention
1 parent 7b06f98 commit b4ca67f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed
 

‎Sources/PostgreSQL/Connection/PostgreSQLConnection+NotifyAndListen.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,10 @@ extension PostgreSQLConnection {
66
handler: @escaping (String) throws -> ()
77
) throws -> Future<Void> {
88
beforeClose = { conn in
9-
let query = PostgreSQLQuery(query: "UNLISTEN \(channelName);")
9+
let query = PostgreSQLQuery(query: "UNLISTEN \"\(channelName)\";")
1010
return conn.send([.query(query)], onResponse: { _ in })
1111
}
12-
let query = PostgreSQLQuery(query: "LISTEN \(channelName);")
12+
let query = PostgreSQLQuery(query: "LISTEN \"\(channelName)\";")
1313
return queue.enqueue([.query(query)], onInput: { message in
1414
switch message {
1515
case let .notificationResponse(notification):
@@ -23,7 +23,7 @@ extension PostgreSQLConnection {
2323

2424
public func notify(
2525
_ channelName: String, message: String) throws -> Future<Void> {
26-
let query = PostgreSQLQuery(query: "NOTIFY \(channelName), '\(message)';")
26+
let query = PostgreSQLQuery(query: "NOTIFY \"\(channelName)\", '\(message)';")
2727
return send([.query(query)]).map(to: Void.self, { _ in })
2828
}
2929
}

0 commit comments

Comments
 (0)