Mercurial > silverbladetech

comparison Messaging/Client/UI/MainWindow.xaml.cs @ 31:7d9de5746f18

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Working version
author adminsh@apollo
date Thu, 22 Mar 2012 08:09:41 +0000
parents 8d574f2d4174
children 874e51b94623
comparison
equal deleted inserted replaced
30:8d574f2d4174 31:7d9de5746f18
21 } 21 }
22 22
23 private void BtnRabbitClick(object sender, RoutedEventArgs e) 23 private void BtnRabbitClick(object sender, RoutedEventArgs e)
24 { 24 {
25 Task.Factory.StartNew(() => 25 Task.Factory.StartNew(() =>
26 { 26 {
27 var cf = new ConnectionFactory {Address = "localhost:" + Settings.RabbitPortNumber}; 27 var cf = new ConnectionFactory
28 {Address = "localhost:" + Settings.RabbitPortNumber};
28 29
29 using (var conn = cf.CreateConnection()) 30 using (var conn = cf.CreateConnection())
30 using (var channel = conn.CreateModel()) 31 using (var channel = conn.CreateModel())
31 { 32 {
32 for (var i = 0; i < MessageCount; i++) 33 for (var i = 0; i < MessageCount; i++)
33 { 34 {
34 channel.BasicPublish("amq.direct", Settings.RabbitQueueName, null, 35 channel.BasicPublish("amq.direct", Settings.RabbitQueueName, null,
35 Encoding.UTF8.GetBytes("hello from the client!")); 36 Encoding.UTF8.GetBytes("hello from the client!"));
36 } 37 }
37 } 38 }
38 }); 39 });
39 } 40 }
40 41
41 private void btnMsmq_Click(object sender, RoutedEventArgs e) 42 private void BtnMsmqClick(object sender, RoutedEventArgs e)
42 { 43 {
43 Task.Factory.StartNew(() => 44 Task.Factory.StartNew(() =>
44 { 45 {
45 var msMq 46 var msMq
46 = !MessageQueue.Exists(Settings.MsmqQueueName) 47 = !MessageQueue.Exists(Settings.MsmqQueueName)
47 ? MessageQueue.Create(Settings.MsmqQueueName) 48 ? MessageQueue.Create(Settings.MsmqQueueName)
48 : new MessageQueue(Settings.MsmqQueueName); 49 : new MessageQueue(Settings.MsmqQueueName);
49 50
50 try 51 try
51 { 52 {
52 for (var i = 0; i < MessageCount; i++) 53 for (var i = 0; i < MessageCount; i++)
53 { 54 {
54 msMq.Send("Sending data to MSMQ at " + DateTime.Now.ToString()); 55 msMq.Send("Sending data to MSMQ at " + DateTime.Now.ToString());
55 } 56 }
56 } 57 }
57 catch (MessageQueueException ee) 58 catch (MessageQueueException ee)
58 { 59 {
59 Console.Write(ee.ToString()); 60 Console.Write(ee.ToString());
60 } 61 }
61 catch (Exception eee) 62 catch (Exception eee)
62 { 63 {
63 Console.Write(eee.ToString()); 64 Console.Write(eee.ToString());
64 } 65 }
65 finally 66 finally
66 { 67 {
67 msMq.Close(); 68 msMq.Close();
68 } 69 }
69 }); 70 });
70 } 71 }
71 72
72 private void btnZeroMq_Click(object sender, RoutedEventArgs e) 73 private void BtnZeroMqClick(object sender, RoutedEventArgs e)
73 { 74 {
75 Task.Factory.StartNew(() =>
76 {
77 using (var ctx = new ZMQ.Context(1))
78 {
79 var socket = ctx.Socket(ZMQ.REQ);
80 socket.Connect("tcp://localhost:5555");
74 81
82 for (var i = 0; i < MessageCount; i++)
83 {
84 socket.Send(Encoding.ASCII.GetBytes("Hello"));
85
86 byte[] message;
87 socket.Recv(out message);
88 }
89 }
90 });
75 } 91 }
76 92
77 private void btnSockets_Click(object sender, RoutedEventArgs e) 93 private void BtnSendAllClick(object sender, RoutedEventArgs e)
78 { 94 {
79 95 Task.Factory.StartNew(() => BtnMsmqClick(this, null));
96 Task.Factory.StartNew(() => BtnRabbitClick(this, null));
97 Task.Factory.StartNew(() => BtnZeroMqClick(this, null));
80 } 98 }
81 } 99 }
82 } 100 }