Give rabbitmqctl a moment to do its job

michaelklishin · michaelklishin · commit 43d7c98c4b5b · 2013-07-16T06:01:44.000+04:00
diff --git a/projects/client/Unit/src/unit/TestConnectionBlocked.cs b/projects/client/Unit/src/unit/TestConnectionBlocked.cs
@@ -63,14 +63,16 @@ public class TestConnectionBlocked : IntegrationFixture {
         [Test]
         public void TestConnectionBlockedNotification()
         {
-	    Conn.ConnectionBlocked   += new ConnectionBlockedEventHandler(HandleBlocked);
-	    Conn.ConnectionUnblocked += new ConnectionUnblockedEventHandler(HandleUnblocked);
+	    Conn.ConnectionBlocked   += HandleBlocked;
+	    Conn.ConnectionUnblocked += HandleUnblocked;
 
 	    Block();
+	    // give rabbitmqctl some time to do its job
+	    Thread.Sleep(800);
 	    Publish(Conn);
 	    lock (lockObject) {
 	        if(!notified) {
-	            Monitor.Wait(lockObject, TimeSpan.FromSeconds(10));
+	            Monitor.Wait(lockObject, TimeSpan.FromSeconds(8));
 	        }
                 Assert.IsTrue(notified);
 	    }

Original file line number	Diff line number	Diff line change
`@@ -63,14 +63,16 @@ public class TestConnectionBlocked : IntegrationFixture {`
`63`	`63`	`[Test]`
`64`	`64`	`public void TestConnectionBlockedNotification()`
`65`	`65`	`{`
`66`		`- Conn.ConnectionBlocked += new ConnectionBlockedEventHandler(HandleBlocked);`
`67`		`- Conn.ConnectionUnblocked += new ConnectionUnblockedEventHandler(HandleUnblocked);`
	`66`	`+ Conn.ConnectionBlocked += HandleBlocked;`
	`67`	`+ Conn.ConnectionUnblocked += HandleUnblocked;`
`68`	`68`
`69`	`69`	`Block();`
	`70`	`+ // give rabbitmqctl some time to do its job`
	`71`	`+ Thread.Sleep(800);`
`70`	`72`	`Publish(Conn);`
`71`	`73`	`lock (lockObject) {`
`72`	`74`	`if(!notified) {`
`73`		`- Monitor.Wait(lockObject, TimeSpan.FromSeconds(10));`
	`75`	`+ Monitor.Wait(lockObject, TimeSpan.FromSeconds(8));`
`74`	`76`	`}`
`75`	`77`	`Assert.IsTrue(notified);`
`76`	`78`	`}`