Add sleep so credit is granted from RMQ (HACK)

Author: lukebakken

rabbitmq_amqp/amqp_management.go

@@ -7,6 +7,7 @@ import (
 	"github.com/Azure/go-amqp"
 	"github.com/google/uuid"
 	"strconv"
+	"time"
 )
 
 var ErrPreconditionFailed = errors.New("precondition Failed")
@@ -57,28 +58,6 @@ func (a *AmqpManagement) ensureReceiverLink(ctx context.Context) error {
 	return nil
 }
 
-//func (a *AmqpManagement) processMessages(ctx context.Context) error {
-//
-//	go func() {
-//
-//		for a.GetStatus() == Open {
-//			msg, err := a.receiver.Receive(ctx, nil) // blocking call
-//			if err != nil {
-//				fmt.Printf("Exiting processMessages %s\n", err)
-//				return
-//			}
-//
-//			if msg != nil {
-//				a.receiver.AcceptMessage(ctx, msg)
-//			}
-//		}
-//
-//		fmt.Printf("Exiting processMessages\n")
-//	}()
-
-//return nil
-//}
-
 func (a *AmqpManagement) ensureSenderLink(ctx context.Context) error {
 	if a.sender == nil {
 		prop := make(map[string]any)
@@ -121,6 +100,8 @@ func (a *AmqpManagement) Open(ctx context.Context, connection IConnection) error
 		return err
 	}
 
+	time.Sleep(time.Second)
+
 	a.lifeCycle.SetStatus(Open)
 	return ctx.Err()
 }