https://issues.apache.org/jira/browse/AMQNET-460
diff --git a/src/main/csharp/MessageConsumer.cs b/src/main/csharp/MessageConsumer.cs
index ca44893..a790092 100755
--- a/src/main/csharp/MessageConsumer.cs
+++ b/src/main/csharp/MessageConsumer.cs
@@ -1642,7 +1642,7 @@
 	                    Thread.Sleep((int) Math.Max(500, failoverRedeliveryWaitPeriod/4));
 	                }
 	            } 
-				while (numberNotReplayed > 0 && expiry < DateTime.Now);
+				while (numberNotReplayed > 0 && expiry > DateTime.Now);
 	        }
 	    }