Add assert for new consumer

xtremekforever · Feb 11, 2025 · 73b6f16 · 73b6f16
1 parent 828900d
commit 73b6f16
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/Sources/MassTransit/MassTransitConsumer.swift b/Sources/MassTransit/MassTransitConsumer.swift
@@ -56,6 +56,8 @@ public actor MassTransitConsumer: Service {
     private func createMessageConsumer<T: MassTransitMessage>(
         _: T.Type, messageType: String
     ) -> AnyAsyncSequence<MassTransitWrapper<T>> {
+        assert(consumers[messageType] == nil, "Consumer for \(messageType) is already registered!")
+
         // Create a stream + continuation
         logger.info("Consuming messages of type \(messageType) on queue \(queueName)...")
         let (stream, continuation) = AsyncStream.makeStream(of: MassTransitWrapper<T>.self)