danderson/ofborg
0
0
Fork 0
forked from the-distro/ofborg
Code Pull requests Activity

rabbitmqconfig: accept SSL option

Browse source
This commit is contained in:
Graham Christensen 2017-11-10 18:34:36 -05:00
parent ea8904e8f7
commit f42dd6bb4c
No known key found for this signature in database
GPG key ID: ACA1C1D120C83D5C
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
ofborg/src/config.rs
View file

@ -12,6 +12,7 @@ pub struct Config {
#[derive(Serialize, Deserialize, Debug)] #[derive(Serialize, Deserialize, Debug)]
pub struct RabbitMQConfig { pub struct RabbitMQConfig {
pub ssl: bool,
pub host: String, pub host: String,
pub username: String, pub username: String,
pub password: String, pub password: String,
@ -31,7 +32,9 @@ pub struct CheckoutConfig {
impl RabbitMQConfig { impl RabbitMQConfig {
pub fn as_uri(&self) -> String{ pub fn as_uri(&self) -> String{
return format!("amqps://{}:{}@{}//", self.username, self.password, self.host); return format!("{}://{}:{}@{}//",
if self.ssl { "amqps" } else { "amqp" },
self.username, self.password, self.host);
} }
} }