Program.cs 834 B

1234567891011121314151617181920212223242526272829
  1. using System;
  2. using Amqp;
  3. namespace send
  4. {
  5. class Program
  6. {
  7. static void Main(string[] args)
  8. {
  9. string url = "amqp://localhost:61616";
  10. string addr = "sampleTopic";
  11. Address a = new Address(url);
  12. Connection c = new Connection(a);
  13. Session s = new Session(c);
  14. SenderLink sl = new SenderLink(s, "sender", addr);
  15. Console.WriteLine("Sending random metrics to " + url + "/" + addr);
  16. var rand = new Random();
  17. while (true) {
  18. Message msg = new Message(rand.Next(10000).ToString());
  19. sl.Send(msg);
  20. Console.WriteLine("Sent: " + msg.Body.ToString());
  21. System.Threading.Thread.Sleep(1000);
  22. }
  23. }
  24. }
  25. }