Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public IConnection GetRabbitMqConnection()
- {
- try
- {
- Thread.Sleep(30000);
- var xml = new GlobalQuote();
- var quote = xml.QuoteConnect();
- JsonSerializer serializer = new JsonSerializer();
- ConnectionFactory connectionFactory = new ConnectionFactory();
- connectionFactory.HostName = quote.Host;
- connectionFactory.UserName = quote.User;
- connectionFactory.Password = quote.Pass;
- connectionFactory.VirtualHost = quote.Vhost;
- connectionFactory.Port = quote.Port;
- connectionFactory.RequestedConnectionTimeout = 5000;
- connectionFactory.RequestedHeartbeat = 30;
- connectionFactory.AutomaticRecoveryEnabled = true;
- return connectionFactory.CreateConnection();
- }
- catch (Exception e)
- {
- log.Info(e.Message);
- return null;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement