add delay on close connection

kubemq-io · May 27, 2021 · 7727513 · 7727513
1 parent 15318be
commit 7727513
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/queues_stream/client.go b/queues_stream/client.go
@@ -3,6 +3,7 @@ package queues_stream
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"github.com/kubemq-io/kubemq-go/pkg/uuid"
 	pb "github.com/kubemq-io/protobuf/go"
@@ -80,6 +81,7 @@ func (q *QueuesStreamClient) AckAll(ctx context.Context, request *AckAllRequest)
 }
 
 func (q *QueuesStreamClient) Close() error {
+	time.Sleep(100 *time.Millisecond)
 	q.upstream.close()
 	q.downstream.close()
 	return q.client.Close()