File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -110,22 +110,22 @@ public void CanNotModifyPayloadAfterPublish()
110
110
QueueDeclareOk q = m . QueueDeclare ( ) ;
111
111
byte [ ] sendBody = new byte [ 1000 ] ;
112
112
var consumer = new EventingBasicConsumer ( m ) ;
113
- var are = new AutoResetEvent ( false ) ;
113
+ var receivedMessage = new AutoResetEvent ( false ) ;
114
114
bool modified = true ;
115
115
consumer . Received += ( o , a ) =>
116
116
{
117
117
if ( a . Body . Span . IndexOf ( ( byte ) 1 ) < 0 )
118
118
{
119
119
modified = false ;
120
120
}
121
- are . Set ( ) ;
121
+ receivedMessage . Set ( ) ;
122
122
} ;
123
123
string tag = m . BasicConsume ( q . QueueName , true , consumer ) ;
124
124
125
125
m . BasicPublish ( "" , q . QueueName , sendBody ) ;
126
126
sendBody . AsSpan ( ) . Fill ( 1 ) ;
127
127
128
- Assert . True ( are . WaitOne ( 2000 ) ) ;
128
+ Assert . True ( receivedMessage . WaitOne ( 5000 ) ) ;
129
129
Assert . False ( modified , "Payload was modified after the return of BasicPublish" ) ;
130
130
131
131
m . BasicCancel ( tag ) ;
You can’t perform that action at this time.
0 commit comments