Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class Rabbit
- {
- public IConnection GetConnection(string hostName, string userName, string password)
- {
- ConnectionFactory connectionFactory = new ConnectionFactory();
- connectionFactory.HostName = "localhost";
- connectionFactory.UserName = "guest";
- connectionFactory.Password = "guest";
- connectionFactory.Port = 5672; // 5672 for regular connections, 5671 for connections that use TLS
- return connectionFactory.CreateConnection();
- }
- public void Send(string queue, string data)
- {
- using (IConnection connection = new ConnectionFactory().CreateConnection())
- {
- using (IModel channel = connection.CreateModel())
- {
- channel.QueueDeclare(queue, false, false, false, null);
- channel.BasicPublish(string.Empty, queue, null, Encoding.UTF8.GetBytes(data));
- }
- }
- }
- public void Receive(string queue)
- {
- using (IConnection connection = new ConnectionFactory().CreateConnection())
- {
- using (IModel channelconsumer = connection.CreateModel())
- {
- channelconsumer.QueueDeclare(queue, false, false, false, null);
- BasicGetResult result = channelconsumer.BasicGet(queue, true);
- if (result != null)
- {
- string data =
- Encoding.UTF8.GetString(result.Body);
- Console.WriteLine(data);
- }
- }
- }
- }
- }
- public ListOfCalculationTasks GetCalculationWorkList()
- {
- using (var webClient = new WebClient() { Encoding = Encoding.UTF8 })
- {
- ....
- var str = webClient.DownloadString(Settings.CalculationWorkerGetUrl);
- var rabbit = new Rabbit();
- rabbit.Send("key", str);
- }
- }
Add Comment
Please, Sign In to add comment