1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/bindings/qpid/dotnet/examples/csharp.example.drain/csharp.example.drain.cs b/cpp/bindings/qpid/dotnet/examples/csharp.example.drain/csharp.example.drain.cs
index 04a0764f7c..da8218bbf7 100644
--- a/cpp/bindings/qpid/dotnet/examples/csharp.example.drain/csharp.example.drain.cs
+++ b/cpp/bindings/qpid/dotnet/examples/csharp.example.drain/csharp.example.drain.cs
@@ -43,9 +43,9 @@ namespace Org.Apache.Qpid.Messaging.Examples {
                 Duration timeout = options.Forever ? 
                                    DurationConstants.FORVER : 
                                    DurationConstants.SECOND * options.Timeout;
-                Message message;
+                Message message = new Message();
 
-                while ((message = receiver.Fetch(timeout)) != null)
+                while (receiver.Fetch(ref message, timeout))
                 {
                     Dictionary<string, object> properties = new Dictionary<string, object>();
                     properties = message.Properties;