the-distro/ofborg
2
0
Fork 1
Code Issues 5 Pull requests 1 Projects Releases Packages Wiki Activity

Fixup connection issues

Browse source
This commit is contained in:
Graham Christensen 2018-01-31 09:46:23 -05:00
parent b47704d6e4
commit 836028cf16
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
1 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
ofborg/src/easyamqp.rs
View file

@ -161,20 +161,29 @@ pub fn session_from_config(config: &RabbitMQConfig) -> Result<amqp::Session, amq
}; };
let mut properties = amqp::Table::new(); let mut properties = amqp::Table::new();
// properties.insert("identity".to_owned(), amqp::TableEntry::LongString(identity.to_owned()));
properties.insert( properties.insert(
"ofborg_version".to_owned(), "ofborg_version".to_owned(),
amqp::TableEntry::LongString(ofborg::VERSION.to_owned()), amqp::TableEntry::LongString(ofborg::VERSION.to_owned()),
); );
amqp::Session::new(amqp::Options { let options = amqp::Options {
host: config.host.clone(), host: config.host.clone(),
port: match scheme {
amqp::AMQPScheme::AMQPS => 5671,
amqp::AMQPScheme::AMQP => 5672,
},
vhost: "/".to_owned(),
login: config.username.clone(), login: config.username.clone(),
password: config.password.clone(), password: config.password.clone(),
scheme: scheme, scheme: scheme,
properties: properties, properties: properties,
..amqp::Options::default() ..amqp::Options::default()
}) };
let session = try!(amqp::Session::new(options));
info!("Connected to {}", &config.host);
return Ok(session);
} }
pub trait TypedWrappers { pub trait TypedWrappers {