diff --git a/packages/core/src/job-queue/job-queue.ts b/packages/core/src/job-queue/job-queue.ts
index 44fefaf548..0683985eef 100644
--- a/packages/core/src/job-queue/job-queue.ts
+++ b/packages/core/src/job-queue/job-queue.ts
@@ -99,7 +99,7 @@ export class JobQueue<Data extends JobData<Data> = object> {
 
         const isBuffered = await this.jobBufferService.add(job);
         if (!isBuffered) {
-            const addedJob = await this.jobQueueStrategy.add(job);
+            const addedJob = await this.jobQueueStrategy.add(job, options);
             return new SubscribableJob(addedJob, this.jobQueueStrategy);
         } else {
             const bufferedJob = new Job({
diff --git a/packages/core/src/service/services/channel.service.ts b/packages/core/src/service/services/channel.service.ts
index 0f76d69c3d..57e49e7ee8 100644
--- a/packages/core/src/service/services/channel.service.ts
+++ b/packages/core/src/service/services/channel.service.ts
@@ -162,7 +162,7 @@ export class ChannelService {
 
         return await this.connection
             .getRepository(ctx, entityType)
-            .createQueryBuilder()
+            .manager.createQueryBuilder()
             .select(`channel.${inverseJunctionColumnName}`, 'channelId')
             .from(junctionTableName, 'channel')
             .where(`channel.${junctionColumnName} = :entityId`, { entityId })