🎉 更新(dependencies): 更新Orleans相关依赖为最新版本并修复项目引用问题。

feijie999 · feijie999 · commit beac4d08d048 · 2024-10-18T16:38:35.000+08:00
diff --git a/Packages.props b/Packages.props
@@ -13,15 +13,17 @@
     <PackageReference Update="Microsoft.Extensions.Hosting.Abstractions" Version="8.0.1" />
     <PackageReference Update="BenchmarkDotNet" Version="0.14.0" />
     
-    <PackageReference Update="Microsoft.Orleans.OrleansProviders" Version="8.2.0"/>
     <PackageReference Update="Microsoft.Orleans.Core" Version="8.2.0" />
     <PackageReference Update="Microsoft.Orleans.Sdk" Version="8.2.0" />
+    <PackageReference Update="Microsoft.Orleans.CodeGenerator" Version="8.2.0" />
     <PackageReference Update="Microsoft.Orleans.Streaming" Version="8.2.0" />
     <PackageReference Update="Microsoft.Orleans.Core.Abstractions" Version="8.2.0" />
     <PackageReference Update="Microsoft.Orleans.Runtime.Abstractions" Version="8.2.0" />
     <PackageReference Update="Microsoft.Orleans.OrleansRuntime" Version="8.2.0" />
     <PackageReference Update="Microsoft.Orleans.TestingHost" Version="8.2.0" />
     <PackageReference Update="Microsoft.Orleans.Reminders" Version="8.2.0" />
+    <PackageReference Update="Microsoft.Orleans.Persistence.Memory" Version="8.2.0" />
+    <PackageReference Update="Microsoft.Orleans.Server" Version="8.2.0" />
 
     <PackageReference Update="System.Buffers" Version="4.5.1" />
     <PackageReference Update="System.Runtime.Loader" Version="4.3.0" />
diff --git a/examples/Transfer.Client/Program.cs b/examples/Transfer.Client/Program.cs
@@ -4,8 +4,11 @@
 using System.Linq;
 using System.Threading.Tasks;
 using IdGen;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 using Orleans;
+using Orleans.Hosting;
 using Transfer.IGrains.Common;
 using Transfer.IGrains.DTx;
 
@@ -14,10 +17,11 @@ namespace Transfer.Client
     internal class Program
     {
         private static readonly IdGenerator IdGen = new IdGenerator(0);
+        private static IHost _host;
 
         private static async Task Main(string[] args)
         {
-            using var client = await StartClientWithRetries();
+             var client = await StartClientWithRetries();
 
             while (true)
             {
@@ -31,7 +35,12 @@ private static async Task Main(string[] args)
                 {
                     await DTx(client);
                 }
+                else
+                {
+                    break;
+                }
             }
+            _host.Dispose();
         }
 
         private static async Task Normal(IClusterClient client)
@@ -46,23 +55,28 @@ private static async Task Normal(IClusterClient client)
                 var topupTaskList = new List<Task>();
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    topupTaskList.AddRange(Enumerable.Range(0, times).Select(x => client.GetGrain<IAccount>(account).TopUp(100, IdGen.CreateId().ToString())));
+                    topupTaskList.AddRange(Enumerable.Range(0, times).Select(x =>
+                        client.GetGrain<IAccount>(account).TopUp(100, IdGen.CreateId().ToString())));
                 }
 
                 topupWatch.Start();
                 await Task.WhenAll(topupTaskList);
                 topupWatch.Stop();
-                Console.WriteLine($"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");
+                Console.WriteLine(
+                    $"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");
+                    Console.WriteLine(
+                        $"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");
                 }
 
                 var transferWatch = new Stopwatch();
                 var transferTaskList = new List<Task>();
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    transferTaskList.AddRange(Enumerable.Range(0, times).Select(x => client.GetGrain<IAccount>(account).Transfer(account + accountCount, 50, IdGen.CreateId().ToString())));
+                    transferTaskList.AddRange(Enumerable.Range(0, times).Select(x =>
+                        client.GetGrain<IAccount>(account)
+                            .Transfer(account + accountCount, 50, IdGen.CreateId().ToString())));
                 }
 
                 transferWatch.Start();
@@ -72,12 +86,14 @@ private static async Task Normal(IClusterClient client)
                     $"{times * accountCount}The transfer is completed, taking: {transferWatch.ElapsedMilliseconds}ms");
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");
+                    Console.WriteLine(
+                        $"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");
                 }
 
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IAccount>(account + accountCount).GetBalance()}");
+                    Console.WriteLine(
+                        $"The balance of account {account} is{await client.GetGrain<IAccount>(account + accountCount).GetBalance()}");
                 }
             }
             catch (Exception e)
@@ -98,16 +114,19 @@ private static async Task DTx(IClusterClient client)
                 var topupTaskList = new List<Task>();
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    topupTaskList.AddRange(Enumerable.Range(0, times).Select(x => client.GetGrain<IDTxAccount>(account).TopUp(100, IdGen.CreateId().ToString())));
+                    topupTaskList.AddRange(Enumerable.Range(0, times).Select(x =>
+                        client.GetGrain<IDTxAccount>(account).TopUp(100, IdGen.CreateId().ToString())));
                 }
 
                 topupWatch.Start();
                 await Task.WhenAll(topupTaskList);
                 topupWatch.Stop();
-                Console.WriteLine($"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");
+                Console.WriteLine(
+                    $"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");
+                    Console.WriteLine(
+                        $"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");
                 }
 
                 var transferWatch = new Stopwatch();
@@ -132,12 +151,14 @@ private static async Task DTx(IClusterClient client)
                     $"{times * accountCount}The transfer is completed, taking: {transferWatch.ElapsedMilliseconds}ms");
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");
+                    Console.WriteLine(
+                        $"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");
                 }
 
                 foreach (var account in Enumerable.Range(0, accountCount))
                 {
-                    Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account + accountCount).GetBalance()}");
+                    Console.WriteLine(
+                        $"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account + accountCount).GetBalance()}");
                 }
             }
             catch (Exception e)
@@ -154,13 +175,13 @@ private static async Task<IClusterClient> StartClientWithRetries(int initializeA
             {
                 try
                 {
-                    var builder = new ClientBuilder()
-                        .UseLocalhostClustering()
-                        .ConfigureApplicationParts(parts =>
-                            parts.AddApplicationPart(typeof(IAccount).Assembly).WithReferences())
+                    var builder = new HostBuilder()
+                        .UseOrleansClient(clientBuilder => clientBuilder.UseLocalhostClustering())
+                        // .ConfigureApplicationParts(parts =>
+                        //     parts.AddApplicationPart(typeof(IAccount).Assembly).WithReferences())
                         .ConfigureLogging(logging => logging.AddConsole());
-                    client = builder.Build();
-                    await client.Connect();
+                    _host = builder.Build();
+                    client = _host.Services.GetService<IClusterClient>();
                     Console.WriteLine("Client successfully connect to silo host");
                     break;
                 }
@@ -181,4 +202,4 @@ private static async Task<IClusterClient> StartClientWithRetries(int initializeA
             return client;
         }
     }
-}
+}
diff --git a/examples/Transfer.Client/Transfer.Client.csproj b/examples/Transfer.Client/Transfer.Client.csproj
@@ -4,7 +4,7 @@
 	  <IsPackable>false</IsPackable>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="Microsoft.Orleans.CodeGenerator.MSBuild" />
+    <PackageReference Include="Microsoft.Orleans.CodeGenerator" />
   </ItemGroup>
 
   <ItemGroup>
diff --git a/examples/Transfer.Grains/Transfer.Grains.csproj b/examples/Transfer.Grains/Transfer.Grains.csproj
@@ -4,7 +4,7 @@
 	  <IsPackable>false</IsPackable>
   </PropertyGroup>
   <ItemGroup>
-    <PackageReference Include="Microsoft.Orleans.CodeGenerator.MSBuild" />
+    <PackageReference Include="Microsoft.Orleans.CodeGenerator" />
   </ItemGroup>
 
   <ItemGroup>
diff --git a/examples/Transfer.Server/Program.cs b/examples/Transfer.Server/Program.cs
@@ -47,13 +47,13 @@ private static IHost CreateHost()
                             options.ServiceId = "Transfer";
                         })
                         .Configure<EndpointOptions>(options => options.AdvertisedIPAddress = IPAddress.Loopback)
-                        .ConfigureApplicationParts(parts =>
-                        {
-                            parts.AddApplicationPart(typeof(Account).Assembly).WithReferences();
-                            parts.AddApplicationPart(typeof(DIDActor).Assembly).WithReferences();
-                            parts.AddApplicationPart(typeof(StreamIdActor).Assembly).WithReferences();
-                        })
-                        .AddSimpleMessageStreamProvider("SMSProvider", options => options.FireAndForgetDelivery = true).AddMemoryGrainStorage("PubSubStore");
+                        // .ConfigureApplicationParts(parts =>
+                        // {
+                        //     parts.AddApplicationPart(typeof(Account).Assembly).WithReferences();
+                        //     parts.AddApplicationPart(typeof(DIDActor).Assembly).WithReferences();
+                        //     parts.AddApplicationPart(typeof(StreamIdActor).Assembly).WithReferences();
+                        // })
+                        .AddMemoryStreams("SMSProvider").AddMemoryGrainStorage("PubSubStore");
                 })
                 .ConfigureServices(serviceCollection =>
                 {
diff --git a/examples/Transfer.Server/Transfer.Server.csproj b/examples/Transfer.Server/Transfer.Server.csproj
@@ -8,11 +8,11 @@
   <ItemGroup>
     <PackageReference Include="Microsoft.Data.Sqlite"/>
     <PackageReference Include="Microsoft.Extensions.Hosting" />
-    <PackageReference Include="Microsoft.Orleans.OrleansProviders" />
-    <PackageReference Include="Microsoft.Orleans.OrleansRuntime" />
+    <PackageReference Include="Microsoft.Orleans.Server" />
     <PackageReference Include="MySqlConnector" />
     <PackageReference Include="Npgsql" />
     <PackageReference Include="Microsoft.Data.SqlClient" />
+    <PackageReference Include="Microsoft.Orleans.Persistence.Memory" />
   </ItemGroup>
 
   <ItemGroup>
diff --git a/test/Vertex.Runtime.Test/Biz/Actors/Account.cs b/test/Vertex.Runtime.Test/Biz/Actors/Account.cs
@@ -1,7 +1,9 @@
 ﻿using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Threading;
 using System.Threading.Tasks;
+using Orleans;
 using Vertex.Abstractions.Event;
 using Vertex.Abstractions.Snapshot;
 using Vertex.Runtime.Actor;
@@ -119,7 +121,7 @@ public async Task RecoverySnapshot_Test()
 
         public async Task Deactivate_Test()
         {
-            await this.OnDeactivateAsync();
+            await this.OnDeactivateAsync(new DeactivationReason(DeactivationReasonCode.None, string.Empty), CancellationToken.None);
             await this.CreateSnapshot();
         }
 
diff --git a/test/Vertex.Runtime.Test/Core/TestSiloConfigurations.cs b/test/Vertex.Runtime.Test/Core/TestSiloConfigurations.cs
@@ -34,7 +34,7 @@ public void Configure(ISiloBuilder hostBuilder)
                         }
                     };
                 }, new EventArchivePolicy("month", (name, time) => $"Vertex_Archive_{name}_{DateTimeOffset.FromUnixTimeSeconds(time):yyyyMM}".ToLower(), table => table.StartsWith("Vertex_Archive".ToLower())));
-            }).AddSimpleMessageStreamProvider("SMSProvider", options => options.FireAndForgetDelivery = true).AddMemoryGrainStorage("PubSubStore");
+            }).AddMemoryStreams("SMSProvider").AddMemoryGrainStorage("PubSubStore");
         }
     }
 }
diff --git a/test/Vertex.Runtime.Test/Vertex.Runtime.Test.csproj b/test/Vertex.Runtime.Test/Vertex.Runtime.Test.csproj
@@ -7,7 +7,7 @@
   <ItemGroup>
     <PackageReference Include="Microsoft.Data.Sqlite" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" />
-    <PackageReference Include="Microsoft.Orleans.CodeGenerator.MSBuild" />
+    <PackageReference Include="Microsoft.Orleans.CodeGenerator" />
     <PackageReference Include="Microsoft.Orleans.TestingHost" />
     <PackageReference Include="xunit" />
     <PackageReference Include="xunit.runner.visualstudio" />
diff --git a/test/Vertex.TxRuntime.Test/Core/TestSiloConfigurations.cs b/test/Vertex.TxRuntime.Test/Core/TestSiloConfigurations.cs
@@ -38,7 +38,7 @@ public void Configure(ISiloBuilder hostBuilder)
                         }
                     };
                 }, new EventArchivePolicy("month", (name, time) => $"Vertex_Archive_{name}_{DateTimeOffset.FromUnixTimeSeconds(time):yyyyMM}".ToLower(), table => table.StartsWith("Vertex_Archive".ToLower())));
-            }).AddSimpleMessageStreamProvider("SMSProvider", options => options.FireAndForgetDelivery = true).AddMemoryGrainStorage("PubSubStore");
+            }) .AddMemoryStreams("SMSProvider").AddMemoryGrainStorage("PubSubStore");
         }
     }
 }
diff --git a/test/Vertex.TxRuntime.Test/Vertex.TxRuntime.Test.csproj b/test/Vertex.TxRuntime.Test/Vertex.TxRuntime.Test.csproj
@@ -7,7 +7,7 @@
   <ItemGroup>
     <PackageReference Include="Microsoft.Data.Sqlite" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" />
-    <PackageReference Include="Microsoft.Orleans.CodeGenerator.MSBuild" />
+    <PackageReference Include="Microsoft.Orleans.CodeGenerator" />
     <PackageReference Include="Microsoft.Orleans.TestingHost"  />
     <PackageReference Include="xunit" />
     <PackageReference Include="xunit.runner.visualstudio" />

Original file line number	Diff line number	Diff line change
`@@ -4,8 +4,11 @@`
`4`	`4`	`using System.Linq;`
`5`	`5`	`using System.Threading.Tasks;`
`6`	`6`	`using IdGen;`
	`7`	`+using Microsoft.Extensions.DependencyInjection;`
	`8`	`+using Microsoft.Extensions.Hosting;`
`7`	`9`	`using Microsoft.Extensions.Logging;`
`8`	`10`	`using Orleans;`
	`11`	`+using Orleans.Hosting;`
`9`	`12`	`using Transfer.IGrains.Common;`
`10`	`13`	`using Transfer.IGrains.DTx;`
`11`	`14`
`@@ -14,10 +17,11 @@ namespace Transfer.Client`
`14`	`17`	`internal class Program`
`15`	`18`	`{`
`16`	`19`	`private static readonly IdGenerator IdGen = new IdGenerator(0);`
	`20`	`+ private static IHost _host;`
`17`	`21`
`18`	`22`	`private static async Task Main(string[] args)`
`19`	`23`	`{`
`20`		`- using var client = await StartClientWithRetries();`
	`24`	`+ var client = await StartClientWithRetries();`
`21`	`25`
`22`	`26`	`while (true)`
`23`	`27`	`{`
`@@ -31,7 +35,12 @@ private static async Task Main(string[] args)`
`31`	`35`	`{`
`32`	`36`	`await DTx(client);`
`33`	`37`	`}`
	`38`	`+ else`
	`39`	`+ {`
	`40`	`+ break;`
	`41`	`+ }`
`34`	`42`	`}`
	`43`	`+ _host.Dispose();`
`35`	`44`	`}`
`36`	`45`
`37`	`46`	`private static async Task Normal(IClusterClient client)`
`@@ -46,23 +55,28 @@ private static async Task Normal(IClusterClient client)`
`46`	`55`	`var topupTaskList = new List<Task>();`
`47`	`56`	`foreach (var account in Enumerable.Range(0, accountCount))`
`48`	`57`	`{`
`49`		`- topupTaskList.AddRange(Enumerable.Range(0, times).Select(x => client.GetGrain<IAccount>(account).TopUp(100, IdGen.CreateId().ToString())));`
	`58`	`+ topupTaskList.AddRange(Enumerable.Range(0, times).Select(x =>`
	`59`	`+ client.GetGrain<IAccount>(account).TopUp(100, IdGen.CreateId().ToString())));`
`50`	`60`	`}`
`51`	`61`
`52`	`62`	`topupWatch.Start();`
`53`	`63`	`await Task.WhenAll(topupTaskList);`
`54`	`64`	`topupWatch.Stop();`
`55`		`- Console.WriteLine($"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");`
	`65`	`+ Console.WriteLine(`
	`66`	`+ $"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");`
`56`	`67`	`foreach (var account in Enumerable.Range(0, accountCount))`
`57`	`68`	`{`
`58`		`- Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");`
	`69`	`+ Console.WriteLine(`
	`70`	`+ $"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");`
`59`	`71`	`}`
`60`	`72`
`61`	`73`	`var transferWatch = new Stopwatch();`
`62`	`74`	`var transferTaskList = new List<Task>();`
`63`	`75`	`foreach (var account in Enumerable.Range(0, accountCount))`
`64`	`76`	`{`
`65`		`- transferTaskList.AddRange(Enumerable.Range(0, times).Select(x => client.GetGrain<IAccount>(account).Transfer(account + accountCount, 50, IdGen.CreateId().ToString())));`
	`77`	`+ transferTaskList.AddRange(Enumerable.Range(0, times).Select(x =>`
	`78`	`+ client.GetGrain<IAccount>(account)`
	`79`	`+ .Transfer(account + accountCount, 50, IdGen.CreateId().ToString())));`
`66`	`80`	`}`
`67`	`81`
`68`	`82`	`transferWatch.Start();`
`@@ -72,12 +86,14 @@ private static async Task Normal(IClusterClient client)`
`72`	`86`	`$"{times * accountCount}The transfer is completed, taking: {transferWatch.ElapsedMilliseconds}ms");`
`73`	`87`	`foreach (var account in Enumerable.Range(0, accountCount))`
`74`	`88`	`{`
`75`		`- Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");`
	`89`	`+ Console.WriteLine(`
	`90`	`+ $"The balance of account {account} is{await client.GetGrain<IAccount>(account).GetBalance()}");`
`76`	`91`	`}`
`77`	`92`
`78`	`93`	`foreach (var account in Enumerable.Range(0, accountCount))`
`79`	`94`	`{`
`80`		`- Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IAccount>(account + accountCount).GetBalance()}");`
	`95`	`+ Console.WriteLine(`
	`96`	`+ $"The balance of account {account} is{await client.GetGrain<IAccount>(account + accountCount).GetBalance()}");`
`81`	`97`	`}`
`82`	`98`	`}`
`83`	`99`	`catch (Exception e)`
`@@ -98,16 +114,19 @@ private static async Task DTx(IClusterClient client)`
`98`	`114`	`var topupTaskList = new List<Task>();`
`99`	`115`	`foreach (var account in Enumerable.Range(0, accountCount))`
`100`	`116`	`{`
`101`		`- topupTaskList.AddRange(Enumerable.Range(0, times).Select(x => client.GetGrain<IDTxAccount>(account).TopUp(100, IdGen.CreateId().ToString())));`
	`117`	`+ topupTaskList.AddRange(Enumerable.Range(0, times).Select(x =>`
	`118`	`+ client.GetGrain<IDTxAccount>(account).TopUp(100, IdGen.CreateId().ToString())));`
`102`	`119`	`}`
`103`	`120`
`104`	`121`	`topupWatch.Start();`
`105`	`122`	`await Task.WhenAll(topupTaskList);`
`106`	`123`	`topupWatch.Stop();`
`107`		`- Console.WriteLine($"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");`
	`124`	`+ Console.WriteLine(`
	`125`	`+ $"{times * accountCount} Recharge completed, taking: {topupWatch.ElapsedMilliseconds}ms");`
`108`	`126`	`foreach (var account in Enumerable.Range(0, accountCount))`
`109`	`127`	`{`
`110`		`- Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");`
	`128`	`+ Console.WriteLine(`
	`129`	`+ $"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");`
`111`	`130`	`}`
`112`	`131`
`113`	`132`	`var transferWatch = new Stopwatch();`
`@@ -132,12 +151,14 @@ private static async Task DTx(IClusterClient client)`
`132`	`151`	`$"{times * accountCount}The transfer is completed, taking: {transferWatch.ElapsedMilliseconds}ms");`
`133`	`152`	`foreach (var account in Enumerable.Range(0, accountCount))`
`134`	`153`	`{`
`135`		`- Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");`
	`154`	`+ Console.WriteLine(`
	`155`	`+ $"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account).GetBalance()}");`
`136`	`156`	`}`
`137`	`157`
`138`	`158`	`foreach (var account in Enumerable.Range(0, accountCount))`
`139`	`159`	`{`
`140`		`- Console.WriteLine($"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account + accountCount).GetBalance()}");`
	`160`	`+ Console.WriteLine(`
	`161`	`+ $"The balance of account {account} is{await client.GetGrain<IDTxAccount>(account + accountCount).GetBalance()}");`
`141`	`162`	`}`
`142`	`163`	`}`
`143`	`164`	`catch (Exception e)`
`@@ -154,13 +175,13 @@ private static async Task<IClusterClient> StartClientWithRetries(int initializeA`
`154`	`175`	`{`
`155`	`176`	`try`
`156`	`177`	`{`
`157`		`- var builder = new ClientBuilder()`
`158`		`- .UseLocalhostClustering()`
`159`		`- .ConfigureApplicationParts(parts =>`
`160`		`- parts.AddApplicationPart(typeof(IAccount).Assembly).WithReferences())`
	`178`	`+ var builder = new HostBuilder()`
	`179`	`+ .UseOrleansClient(clientBuilder => clientBuilder.UseLocalhostClustering())`
	`180`	`+ // .ConfigureApplicationParts(parts =>`
	`181`	`+ // parts.AddApplicationPart(typeof(IAccount).Assembly).WithReferences())`
`161`	`182`	`.ConfigureLogging(logging => logging.AddConsole());`
`162`		`- client = builder.Build();`
`163`		`- await client.Connect();`
	`183`	`+ _host = builder.Build();`
	`184`	`+ client = _host.Services.GetService<IClusterClient>();`
`164`	`185`	`Console.WriteLine("Client successfully connect to silo host");`
`165`	`186`	`break;`
`166`	`187`	`}`
`@@ -181,4 +202,4 @@ private static async Task<IClusterClient> StartClientWithRetries(int initializeA`
`181`	`202`	`return client;`
`182`	`203`	`}`
`183`	`204`	`}`
`184`		`-}`
	`205`	`+}`
Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ public void Configure(ISiloBuilder hostBuilder)`
`34`	`34`	`}`
`35`	`35`	`};`
`36`	`36`	`}, new EventArchivePolicy("month", (name, time) => $"Vertex_Archive_{name}_{DateTimeOffset.FromUnixTimeSeconds(time):yyyyMM}".ToLower(), table => table.StartsWith("Vertex_Archive".ToLower())));`
`37`		`- }).AddSimpleMessageStreamProvider("SMSProvider", options => options.FireAndForgetDelivery = true).AddMemoryGrainStorage("PubSubStore");`
	`37`	`+ }).AddMemoryStreams("SMSProvider").AddMemoryGrainStorage("PubSubStore");`
`38`	`38`	`}`
`39`	`39`	`}`
`40`	`40`	`}`
Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ public void Configure(ISiloBuilder hostBuilder)`
`38`	`38`	`}`
`39`	`39`	`};`
`40`	`40`	`}, new EventArchivePolicy("month", (name, time) => $"Vertex_Archive_{name}_{DateTimeOffset.FromUnixTimeSeconds(time):yyyyMM}".ToLower(), table => table.StartsWith("Vertex_Archive".ToLower())));`
`41`		`- }).AddSimpleMessageStreamProvider("SMSProvider", options => options.FireAndForgetDelivery = true).AddMemoryGrainStorage("PubSubStore");`
	`41`	`+ }) .AddMemoryStreams("SMSProvider").AddMemoryGrainStorage("PubSubStore");`
`42`	`42`	`}`
`43`	`43`	`}`
`44`	`44`	`}`