in src/Libs/Common/Extensions/MessageClientExtensions.cs [26:45]
public static Task<CommandMessage> CrashClientsAsync(this IMessageClient client) =>
CrashAsync(client, Roles.Clients);
public static Task<CommandMessage> CrashAppServersAsync(this IMessageClient client) =>
CrashAsync(client, Roles.AppServers);
#endregion
#region Commands To Clients
public static async Task<CommandMessage> BroadcastCoordinateTime(this IMessageClient client)
{
var command = new SetCoordinatorTimeParameters()
{
CoordinatorTime = DateTime.UtcNow.Ticks,
};
var message = new CommandMessage { Command = Commands.Clients.SetCoordinatorTime, Parameters = JObject.FromObject(command) };
await client.SendCommandAsync(Roles.Clients, message);
return message;
}