Resolves #1

joel-jeremy · joel-jeremy · commit 18746ae4b34c · 2018-03-27T09:26:42.000+08:00
diff --git a/Src/Xer.Messaginator.Extensions.MessageSources.Http/HttpMessageSource.cs b/Src/Xer.Messaginator.Extensions.MessageSources.Http/HttpMessageSource.cs
@@ -110,6 +110,11 @@ internal HttpMessageSource(string url,
                 .UseUrls(Url);
 
             _host = ConfigureWebHost(webHostBuilder);
+
+            if (_host == null)
+            {
+                return Task.FromException(new InvalidOperationException("No web host was configured."));
+            }
  
             return _host.StartAsync(cancellationToken);
         }
@@ -121,7 +126,7 @@ internal HttpMessageSource(string url,
         /// <returns>Asynchronous task.</returns>
         public Task StopReceivingAsync(CancellationToken cancellationToken = default(CancellationToken))
         {
-            return _host.StopAsync(cancellationToken);
+            return _host?.StopAsync(cancellationToken);
         }
 
         #endregion IMessageSource<TMessage> Implementation

Original file line number	Diff line number	Diff line change
`@@ -110,6 +110,11 @@ internal HttpMessageSource(string url,`
`110`	`110`	`.UseUrls(Url);`
`111`	`111`
`112`	`112`	`_host = ConfigureWebHost(webHostBuilder);`
	`113`	`+`
	`114`	`+ if (_host == null)`
	`115`	`+ {`
	`116`	`+ return Task.FromException(new InvalidOperationException("No web host was configured."));`
	`117`	`+ }`
`113`	`118`
`114`	`119`	`return _host.StartAsync(cancellationToken);`
`115`	`120`	`}`
`@@ -121,7 +126,7 @@ internal HttpMessageSource(string url,`
`121`	`126`	`/// <returns>Asynchronous task.</returns>`
`122`	`127`	`public Task StopReceivingAsync(CancellationToken cancellationToken = default(CancellationToken))`
`123`	`128`	`{`
`124`		`- return _host.StopAsync(cancellationToken);`
	`129`	`+ return _host?.StopAsync(cancellationToken);`
`125`	`130`	`}`
`126`	`131`
`127`	`132`	`#endregion IMessageSource<TMessage> Implementation`