Fix panic

When shutting down a receiver a panic ensues because the waitGroup
index becomes less than zero

Some miscellaneous spelling errors fixed.

Found during development of anothet feature. Fix was tested during
feature development.

AB#9875

azbus/receiver.go

@@ -163,7 +163,7 @@ func (r *Receiver) String() string {
 func (r *Receiver) processMessage(ctx context.Context, count int, maxDuration time.Duration, msg *ReceivedMessage, handler Handler) {
 	now := time.Now()
 
-	// the context wont have a trace span on it yet, so stick with the reciever logger instance
+	// the context wont have a trace span on it yet, so stick with the receiver logger instance
 
 	r.log.Debugf("Processing message %d id %s", count, msg.MessageID)
 	disp, ctx, err := r.handleReceivedMessageWithTracingContext(ctx, msg, handler)
@@ -240,7 +240,6 @@ func (r *Receiver) receiveMessages(ctx context.Context) error {
 				select {
 				case <-rctx.Done():
 					rr.log.Debugf("Stop worker %d", ii)
-					wg.Done()
 					return
 				case msg := <-msgs:
 					func(rrctx context.Context) {

errhandling/errb2c.go

@@ -47,7 +47,7 @@ func (e *ErrB2C) WithErrorString(log Logger, errString string) error {
 	if _, scanErr := fmt.Sscanf(errString, b2cFmtString,
 		&e.APIVersion, &e.Status, &e.UserMessage); scanErr != nil {
 
-		log.Infof("scan error: %v", scanErr)
+		log.Debugf("scan error: %v", scanErr)
 		return scanErr
 	}
 
@@ -72,15 +72,15 @@ func GetErrB2c(ctx context.Context, err error) (*ErrB2C, error) {
 
 	// chance it is a status.Error (can't access status.Error as its part of an internal package)
 	if !strings.HasPrefix(err.Error(), grpcErrPrefix) {
-		log.Infof("error is not b2c error: %v", err)
+		log.Debugf("error is not b2c error: %v", err)
 		return nil, err
 	}
 
 	// can't use errors.Unwrap because status.Error doesn't implement Unwrap method
 	b2cErrString := strings.TrimPrefix(err.Error(), grpcErrPrefix)
 
 	if convErr := errB2C.WithErrorString(log, b2cErrString); convErr != nil {
-		log.Infof("unable to add error string: %v", convErr)
+		log.Debugf("unable to add error string: %v", convErr)
 		return nil, convErr
 	}
 

restproxyserver/restproxyserver.go

@@ -74,7 +74,7 @@ func SetQueryParameterParser(p QueryParameterParser) RESTProxyServerOption {
 	}
 }
 
-// WithIncomingHeaderMatcher adds an intercepror that matches header values.
+// WithIncomingHeaderMatcher adds an interceptor that matches header values.
 func WithIncomingHeaderMatcher(o HeaderMatcherFunc) RESTProxyServerOption {
 	return func(g *RESTProxyServer) {
 		if o != nil && !reflect.ValueOf(o).IsNil() {