File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -18,6 +18,7 @@ import (
1818 "context"
1919 "errors"
2020 "fmt"
21+ "log"
2122 "testing"
2223 "time"
2324
@@ -689,12 +690,11 @@ func TestExactlyOnceDelivery_AckRetryDeadlineExceeded(t *testing.T) {
689690
690691 s .ReceiveSettings = ReceiveSettings {
691692 NumGoroutines : 1 ,
692- // This needs to be greater than total deadline otherwise the message will be redelivered.
693- MinExtensionPeriod : 30 * time .Second ,
694693 }
695694 // Override the default timeout here so this test doesn't take 10 minutes.
696695 exactlyOnceDeliveryRetryDeadline = 10 * time .Second
697696 err = s .Receive (ctx , func (ctx context.Context , msg * Message ) {
697+ log .Printf ("received message: %v\n " , msg )
698698 ar := msg .AckWithResult ()
699699 s , err := ar .Get (ctx )
700700 if s != AcknowledgeStatusOther {
You can’t perform that action at this time.
0 commit comments