diff --git a/README.md b/README.md index 4a2dc1f..c46f979 100644 --- a/README.md +++ b/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 diff --git a/v2/processor.go b/v2/processor.go index 5927685..1added6 100644 --- a/v2/processor.go +++ b/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)