retry returns Task, not Task<unit>

fivepmtechnology · May 10, 2012 · f0c3839 · f0c3839
1 parent d8ec31c
commit f0c3839
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/src/MassTransit.Async/Retries.fs b/src/MassTransit.Async/Retries.fs
@@ -3,8 +3,12 @@
 module Retries =
     open MassTransit.Async.AsyncRetry
     open System
+    open System.Threading.Tasks
+
+    [<Serializable>]
+    type Unit() = class end
 
     /// Execute the action, retrying according to the specified policy
     [<CompiledName("Retry")>]
     let retry ( policy : RetryPolicy ) ( action : Action ) =
-        AsyncRetryBuilder policy { action |> ignore } |> Async.StartAsTask
+        AsyncRetryBuilder policy { action |> ignore } |> Async.StartAsTask :> Task
diff --git a/src/MassTransit.Transports.AzureServiceBus/OutboundTransportImpl.cs b/src/MassTransit.Transports.AzureServiceBus/OutboundTransportImpl.cs
@@ -116,7 +116,7 @@ public void Send(ISendContext context)
 									
 									return brokeredMessage;
 								}, 1);
-                            });
+                            }).Wait();
 						}
 					});
 		}