Guest User

Untitled

a guest
Dec 12th, 2018
181
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.81 KB | None | 0 0
  1. public class Rabbit
  2. {
  3. public IConnection GetConnection(string hostName, string userName, string password)
  4. {
  5. ConnectionFactory connectionFactory = new ConnectionFactory();
  6. connectionFactory.HostName = "localhost";
  7. connectionFactory.UserName = "guest";
  8. connectionFactory.Password = "guest";
  9. connectionFactory.Port = 5672; // 5672 for regular connections, 5671 for connections that use TLS
  10. return connectionFactory.CreateConnection();
  11. }
  12.  
  13. public void Send(string queue, string data)
  14. {
  15. using (IConnection connection = new ConnectionFactory().CreateConnection())
  16. {
  17. using (IModel channel = connection.CreateModel())
  18. {
  19. channel.QueueDeclare(queue, false, false, false, null);
  20. channel.BasicPublish(string.Empty, queue, null, Encoding.UTF8.GetBytes(data));
  21. }
  22. }
  23. }
  24.  
  25. public void Receive(string queue)
  26. {
  27. using (IConnection connection = new ConnectionFactory().CreateConnection())
  28. {
  29. using (IModel channelconsumer = connection.CreateModel())
  30. {
  31. channelconsumer.QueueDeclare(queue, false, false, false, null);
  32. BasicGetResult result = channelconsumer.BasicGet(queue, true);
  33. if (result != null)
  34. {
  35. string data =
  36. Encoding.UTF8.GetString(result.Body);
  37. Console.WriteLine(data);
  38. }
  39. }
  40. }
  41. }
  42. }
  43.  
  44. public ListOfCalculationTasks GetCalculationWorkList()
  45. {
  46. using (var webClient = new WebClient() { Encoding = Encoding.UTF8 })
  47. {
  48. ....
  49. var str = webClient.DownloadString(Settings.CalculationWorkerGetUrl);
  50. var rabbit = new Rabbit();
  51.  
  52. rabbit.Send("key", str);
  53. }
  54. }
Add Comment
Please, Sign In to add comment