diff --git a/src/subscriptions/onJobActive.ts b/src/subscriptions/onJobActive.ts
index 26fb0c4..7fff3cc 100644
--- a/src/subscriptions/onJobActive.ts
+++ b/src/subscriptions/onJobActive.ts
@@ -11,7 +11,7 @@ export function createOnJobActiveFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobActivePayload',
+      name: `${opts.typePrefix}OnJobActivePayload`,
       fields: {
         job: getJobTC(sc, opts),
         queue: getQueueTC(sc, opts).NonNull,
diff --git a/src/subscriptions/onJobCompleted.ts b/src/subscriptions/onJobCompleted.ts
index 929de03..795c49c 100644
--- a/src/subscriptions/onJobCompleted.ts
+++ b/src/subscriptions/onJobCompleted.ts
@@ -11,7 +11,7 @@ export function createOnJobCompletedFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobCompletedPayload',
+      name: `${opts.typePrefix}OnJobCompletedPayload`,
       fields: {
         job: getJobTC(sc, opts),
         queue: getQueueTC(sc, opts).NonNull,
diff --git a/src/subscriptions/onJobDelayed.ts b/src/subscriptions/onJobDelayed.ts
index 3b84316..b3c6b65 100644
--- a/src/subscriptions/onJobDelayed.ts
+++ b/src/subscriptions/onJobDelayed.ts
@@ -11,7 +11,7 @@ export function createOnJobDelayedFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobDelayedPayload',
+      name: `${opts.typePrefix}OnJobDelayedPayload`,
       fields: {
         job: getJobTC(sc, opts),
         queue: getQueueTC(sc, opts).NonNull,
diff --git a/src/subscriptions/onJobFailed.ts b/src/subscriptions/onJobFailed.ts
index 8be8679..26aa34b 100644
--- a/src/subscriptions/onJobFailed.ts
+++ b/src/subscriptions/onJobFailed.ts
@@ -11,7 +11,7 @@ export function createOnJobFailedFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobFailedPayload',
+      name: `${opts.typePrefix}OnJobFailedPayload`,
       fields: {
         job: getJobTC(sc, opts),
         queue: getQueueTC(sc, opts).NonNull,
diff --git a/src/subscriptions/onJobProgress.ts b/src/subscriptions/onJobProgress.ts
index ae2e563..d07a13a 100644
--- a/src/subscriptions/onJobProgress.ts
+++ b/src/subscriptions/onJobProgress.ts
@@ -11,7 +11,7 @@ export function createOnJobProgressFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobProgressPayload',
+      name: `${opts.typePrefix}OnJobProgressPayload`,
       fields: {
         job: getJobTC(sc, opts),
         queue: getQueueTC(sc, opts).NonNull,
diff --git a/src/subscriptions/onJobRemoved.ts b/src/subscriptions/onJobRemoved.ts
index 0194252..7b435e5 100644
--- a/src/subscriptions/onJobRemoved.ts
+++ b/src/subscriptions/onJobRemoved.ts
@@ -10,7 +10,7 @@ export function createOnJobRemovedFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobRemovedPayload',
+      name: `${opts.typePrefix}OnJobRemovedPayload`,
       fields: {
         queue: getQueueTC(sc, opts).NonNull,
         jobId: 'String!',
diff --git a/src/subscriptions/onJobStalled.ts b/src/subscriptions/onJobStalled.ts
index ff07a48..fba3923 100644
--- a/src/subscriptions/onJobStalled.ts
+++ b/src/subscriptions/onJobStalled.ts
@@ -11,7 +11,7 @@ export function createOnJobStalledFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobStalledPayload',
+      name: `${opts.typePrefix}OnJobStalledPayload`,
       fields: {
         job: getJobTC(sc, opts),
         queue: getQueueTC(sc, opts).NonNull,
diff --git a/src/subscriptions/onJobWaiting.ts b/src/subscriptions/onJobWaiting.ts
index bde0b4f..4b0667b 100644
--- a/src/subscriptions/onJobWaiting.ts
+++ b/src/subscriptions/onJobWaiting.ts
@@ -11,7 +11,7 @@ export function createOnJobWaitingFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnJobWaitingPayload',
+      name: `${opts.typePrefix}OnJobWaitingPayload`,
       fields: {
         job: getJobTC(sc, opts),
         queue: getQueueTC(sc, opts).NonNull,
diff --git a/src/subscriptions/onQueuePaused.ts b/src/subscriptions/onQueuePaused.ts
index 7f0a483..f0eeb0b 100644
--- a/src/subscriptions/onQueuePaused.ts
+++ b/src/subscriptions/onQueuePaused.ts
@@ -10,7 +10,7 @@ export function createOnQueuePausedFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnQueuePausedPayload',
+      name: `${opts.typePrefix}OnQueuePausedPayload`,
       fields: {
         queue: getQueueTC(sc, opts).NonNull,
         queueName: 'String!',
diff --git a/src/subscriptions/onQueueResumed.ts b/src/subscriptions/onQueueResumed.ts
index 632684b..25e07a2 100644
--- a/src/subscriptions/onQueueResumed.ts
+++ b/src/subscriptions/onQueueResumed.ts
@@ -10,7 +10,7 @@ export function createOnQueueResumedFC(
 ): ObjectTypeComposerFieldConfigAsObjectDefinition<any, any> {
   return {
     type: sc.createObjectTC({
-      name: 'OnQueueResumedPayload',
+      name: `${opts.typePrefix}OnQueueResumedPayload`,
       fields: {
         queue: getQueueTC(sc, opts).NonNull,
         queueName: 'String!',
diff --git a/src/types/queue/Queue.jobsMemoryUsageAvg.ts b/src/types/queue/Queue.jobsMemoryUsageAvg.ts
index fd6c71b..1605cca 100644
--- a/src/types/queue/Queue.jobsMemoryUsageAvg.ts
+++ b/src/types/queue/Queue.jobsMemoryUsageAvg.ts
@@ -12,7 +12,7 @@ export function createJobsMemoryUsageAvgFC(
     args: {
       keySetName: {
         type: sc.createEnumTC({
-          name: 'keySetNamesEnum',
+          name: `${opts?.typePrefix}KeySetNamesEnum`,
           values: {
             COMPLETED: { value: 'completed' },
             FAILED: { value: 'failed' },