diff --git a/src/PgCache.ts b/src/PgCache.ts index b3cc30a..04c8ecd 100644 --- a/src/PgCache.ts +++ b/src/PgCache.ts @@ -324,7 +324,7 @@ export function PgCache(options: PgCacheOptions): ClassDecorator { this.pubSub.on('connect', async () => { await install( - Object.keys(this.pgCacheChannels), + Object.keys(pgChannels), this.pubSub.pgClient, triggerDef(options.triggerDefinition), logger,