Deprecate MultiProcessor API

README.md

@@ -38,9 +38,8 @@ type ProcessorOptions struct {
 
 ### MultiProcessor
 
-`NewMultiProcessor` takes in a list of receivers and a message handler. It creates a processor for each receiver and starts them concurrently.
-
-see [Processor and MultiProcessor examples](v2/processor_test.go)
+Deprecated: `NewMultiProcessor`, `ReceiverEx`, and `NewReceiverEx` are deprecated and will be removed in a future version.
+Use `NewProcessor` with one receiver per processor instead.
 
 ## Middlewares:
 GoSHuttle provides a few middleware to simplify the implementation of the message handler in the application code

v2/processor.go

@@ -26,11 +26,19 @@ type MessageSettler interface {
 	RenewMessageLock(ctx context.Context, message *azservicebus.ReceivedMessage, options *azservicebus.RenewMessageLockOptions) error
 }
 
+// ReceiverEx names a Service Bus receiver for NewMultiProcessor.
+//
+// Deprecated: NewMultiProcessor is deprecated and will be removed in a future version.
+// Use NewProcessor with one receiver per Processor instead.
 type ReceiverEx struct { // shuttle.Receiver is already an exported interface
 	name       string
 	sbReceiver Receiver
 }
 
+// NewReceiverEx creates a named receiver for NewMultiProcessor.
+//
+// Deprecated: NewMultiProcessor is deprecated and will be removed in a future version.
+// Use NewProcessor with one receiver per Processor instead.
 func NewReceiverEx(name string, sbReceiver Receiver) *ReceiverEx {
 	return &ReceiverEx{
 		name:       name,
@@ -124,6 +132,9 @@ func NewProcessor(receiver Receiver, handler HandlerFunc, options *ProcessorOpti
 }
 
 // NewMultiProcessor creates a new processor with a list of receivers and a handler.
+//
+// Deprecated: NewMultiProcessor is deprecated and will be removed in a future version.
+// Use NewProcessor with one receiver per Processor instead.
 func NewMultiProcessor(receiversEx []*ReceiverEx, handler HandlerFunc, options *ProcessorOptions) *Processor {
 	opts := applyProcessorOptions(options)
 	var receivers = make(map[string]*ReceiverEx)