Error fix

CarlosGamero · CarlosGamero · commit d057fd425519 · 2025-06-02T15:09:43.000+02:00
diff --git a/packages/core/lib/queues/MessageSchemaContainer.ts b/packages/core/lib/queues/MessageSchemaContainer.ts
@@ -13,7 +13,7 @@ export class MessageSchemaContainer<MessagePayloadSchemas extends object> {
   private readonly messageTypeField?: string
 
   constructor(options: MessageSchemaContainerOptions<MessagePayloadSchemas>) {
-    if (options.messageTypeField === undefined && options.messageSchemas.length === 1) {
+    if (options.messageTypeField === undefined && options.messageSchemas.length > 1) {
       throw new Error(
         'if messageTypeField is not provided, messageSchemas must have a single schema',
       )

Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@ export class MessageSchemaContainer<MessagePayloadSchemas extends object> {`
`13`	`13`	`private readonly messageTypeField?: string`
`14`	`14`
`15`	`15`	`constructor(options: MessageSchemaContainerOptions<MessagePayloadSchemas>) {`
`16`		`- if (options.messageTypeField === undefined && options.messageSchemas.length === 1) {`
	`16`	`+ if (options.messageTypeField === undefined && options.messageSchemas.length > 1) {`
`17`	`17`	`throw new Error(`
`18`	`18`	`'if messageTypeField is not provided, messageSchemas must have a single schema',`
`19`	`19`	`)`