File tree Expand file tree Collapse file tree 2 files changed +12
-12
lines changed
RabbitMQ.Client/src/client/api Expand file tree Collapse file tree 2 files changed +12
-12
lines changed Original file line number Diff line number Diff line change @@ -93,8 +93,9 @@ public interface IModel: IDisposable
93
93
///</remarks>
94
94
event CallbackExceptionEventHandler CallbackException ;
95
95
96
- ///<summary>Signalled when a RecoverOk is received from the
97
- ///server. </summary>
96
+ ///<summary>All messages received before this fires that haven't been
97
+ ///ack'ed will be redelivered. All messages received afterwards won't
98
+ ///be.</summary>
98
99
event BasicRecoverOkEventHandler BasicRecoverOk ;
99
100
100
101
///<summary>Signalled when an unexpected message is delivered
@@ -630,10 +631,7 @@ void HandleBasicGetOk(ulong deliveryTag,
630
631
void HandleBasicGetEmpty ( ) ;
631
632
632
633
///<summary>Handle incoming Basic.RecoverOk methods
633
- ///received in reply to Basic.Recover . All messages
634
- ///received before this is invoked that haven't been
635
- ///ack'ed will be redelivered. All messages received
636
- ///afterwards won't be.
634
+ ///received in reply to Basic.Recover.
637
635
///</summary>
638
636
void HandleBasicRecoverOk ( ) ;
639
637
Original file line number Diff line number Diff line change 59
59
using System ;
60
60
using System . IO ;
61
61
using System . Text ;
62
+ using System . Threading ;
62
63
using System . Collections ;
63
64
64
65
using RabbitMQ . Client . Impl ;
@@ -117,12 +118,13 @@ public void TestRecoverAfterCancel_()
117
118
}
118
119
119
120
[ Test ]
120
- public void TestRecoverCallback ( )
121
- {
122
- int callbackCount = 0 ;
123
- Channel . BasicRecoverOk += ( sender , eventArgs ) => callbackCount ++ ;
124
- Channel . BasicRecover ( false ) ;
125
- Assert . AreEqual ( 1 , callbackCount ) ;
121
+ public void TestRecoverCallback ( )
122
+ {
123
+ int callbackCount = 0 ;
124
+ Channel . BasicRecoverOk += ( sender , eventArgs ) => callbackCount ++ ;
125
+ Channel . BasicRecover ( false ) ;
126
+ Thread . Sleep ( 100 ) ;
127
+ Assert . AreEqual ( 1 , callbackCount ) ;
126
128
}
127
129
128
130
}
You can’t perform that action at this time.
0 commit comments