File tree Expand file tree Collapse file tree 1 file changed +23
-0
lines changed
projects/client/Unit/src/unit Expand file tree Collapse file tree 1 file changed +23
-0
lines changed Original file line number Diff line number Diff line change @@ -91,6 +91,29 @@ public void TestWaitForConfirmsWithTimeout_MessageNacked_WaitingHasTimedout_Retu
91
91
} ) ;
92
92
}
93
93
94
+ [ Test ]
95
+ public void TestWaitForConfirmsWithTimeout_AllMessagesAcked_WaitingHasTimedout_ReturnTrue ( )
96
+ {
97
+ TestWaitForConfirms ( 200 , ( ch ) =>
98
+ {
99
+ Assert . IsTrue ( ch . WaitForConfirms ( TimeSpan . FromMilliseconds ( 1 ) ) ) ;
100
+ } ) ;
101
+ }
102
+
103
+ [ Test ]
104
+ public void TestWaitForConfirmsWithTimeout_MessageNacked_WaitingHasTimedout_ReturnFalse ( )
105
+ {
106
+ TestWaitForConfirms ( 200 , ( ch ) =>
107
+ {
108
+ var message = ch . BasicGet ( QueueName , false ) ;
109
+
110
+ var fullModel = ch as IFullModel ;
111
+ fullModel . HandleBasicNack ( message . DeliveryTag , false , false ) ;
112
+
113
+ Assert . IsFalse ( ch . WaitForConfirms ( TimeSpan . FromMilliseconds ( 1 ) ) ) ;
114
+ } ) ;
115
+ }
116
+
94
117
[ Test ]
95
118
public void TestWaitForConfirmsWithEvents ( )
96
119
{
You can’t perform that action at this time.
0 commit comments