This commit is contained in:
parent
6f05bd0f85
commit
fd4ddaf6d6
|
@ -36,7 +36,7 @@ func (s *postgres) Subscribe(topic string, sub Subscriber) error {
|
|||
|
||||
func (s *postgres) Unsubscribe(topic, callback string) error {
|
||||
_, err := s.db.Exec(
|
||||
`DELETE FROM "subscribers" WHERE "topic" = ? AND "callback" = $1`,
|
||||
`DELETE FROM "subscribers" WHERE "topic" = $1 AND "callback" = $2`,
|
||||
topic,
|
||||
callback,
|
||||
)
|
||||
|
|
Loading…
Reference in New Issue
Block a user