Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- using System.ServiceModel;
- using System.ServiceModel.Channels;
- using System.ServiceModel.Web;
- using RabbitMQ.Client;
- using RabbitMQ.Client.Events;
- using System.Threading;
- namespace ConsoleApp5
- {
- class Program
- {
- class MyConsumer : DefaultBasicConsumer
- {
- public MyConsumer(IModel model) : base(model) { }
- public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool
- redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
- {
- var message = Encoding.UTF8.GetString(body);
- // show message
- }
- private static void Receiv(object model, BasicDeliverEventArgs ea)
- {
- var body = ea.Body;
- var message = Encoding.UTF8.GetString(body);
- Console.WriteLine(" [x] Received:'{0}'", message, ConsoleColor.Yellow);
- }
- }
- static void Main(string[] args)
- {
- // host: https://api.cloudamqp.com/console/dd005f1a-f7de-408c-a2a6-3f3bdd8acfa8/details
- /*
- var factory = new ConnectionFactory()
- {
- UserName = "dahjdrhx",
- Password = "ng-DairYiYJDTY9JyemWFB9By5WqxXcA",
- HostName = "eagle.rmq.cloudamqp.com",
- VirtualHost = "dahjdrhx"
- };
- */
- // client http://localhost:15672/#/vhosts
- Thread.Sleep(1000);
- var factory = new ConnectionFactory()
- {
- UserName = "guest",
- Password = "guest",
- HostName = "localhost",
- VirtualHost = "103057"
- };
- var connection = factory.CreateConnection();
- var channel = connection.CreateModel();
- var consumer = new EventingBasicConsumer(channel);
- // ZAD 2
- channel.BasicQos(0, 10, false);
- channel.BasicQos(0, 15, true);
- channel.BasicConsume("message_queue", false, consumer);
- // ZAD 2
- // ZAD 1
- consumer.Received += (ch, ea) =>
- {
- var body = ea.Body;
- // positively acknowledge a single delivery, the message will
- // be discarded
- var message = Encoding.UTF8.GetString(body);
- Console.WriteLine(" [x] Received:'{0}'", message, ConsoleColor.Yellow);
- //channel.BasicAck(ea.DeliveryTag, false);
- };
- //String consumerTag = channel.BasicConsume("message_queue", false, consumer);
- // ZAD 1
- // ZAD 3
- /*
- var responseBytes = Encoding.UTF8.GetBytes(DateTime.Now.ToLongTimeString());
- var replyProps = channel.CreateBasicProperties();
- replyProps.CorrelationId = prop.CorrelationId;
- channel.BasicPublish("", prop.ReplyTo, replyProps, responseBytes);
- */
- // ZAD 3
- Console.ReadKey();
- channel.Close();
- connection.Close();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement