41 lines
1.2 KiB
C#
41 lines
1.2 KiB
C#
|
using Publisher;
|
|||
|
|
using System.Text;
|
|||
|
|
|
|||
|
|
var rabbitHost = Environment.GetEnvironmentVariable("RABBIT_HOST") ?? "localhost";
|
|||
|
|
var rabbitUsername = Environment.GetEnvironmentVariable("RABBIT_USERNAME") ?? "user";
|
|||
|
|
var rabbitPassword = Environment.GetEnvironmentVariable("RABBIT_PASSWORD") ?? "password";
|
|||
|
|
var rabbitExchange = Environment.GetEnvironmentVariable("RABBIT_EXCHANGE") ?? "ReportIn";
|
|||
|
|
|
|||
|
|
var sender = new Sender(rabbitHost, rabbitUsername, rabbitPassword);
|
|||
|
|
|
|||
|
|
sender.AddExcange(rabbitExchange);
|
|||
|
|
|
|||
|
|
var rnd = new Random();
|
|||
|
|
|
|||
|
|
while (true)
|
|||
|
|
{
|
|||
|
|
StringBuilder sb = new();
|
|||
|
|
|
|||
|
|
var type = rnd.Next();
|
|||
|
|
switch (type%2)
|
|||
|
|
{
|
|||
|
|
case 0:
|
|||
|
|
{
|
|||
|
|
sb.Append($"Был запрошен отчет о данных под номером {rnd.Next(1000)}");
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
case 1:
|
|||
|
|
{
|
|||
|
|
sb.Append($"Был запрошен отчет об ошибках под номером {rnd.Next(1000)}");
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
var text = sb.ToString();
|
|||
|
|
Console.WriteLine($"Было опубликовано сообщение: {text}");
|
|||
|
|
sender.PublishToExchange(rabbitExchange, text);
|
|||
|
|
|
|||
|
|
await Task.Delay(1000);
|
|||
|
|
}
|
|||
|
|
|