Commit ebb0ff86 authored by Dave Syer's avatar Dave Syer

Merge remote-tracking branch 'origin/1.3.x'

parents c85948ac 9c0679b1
...@@ -109,6 +109,9 @@ public class RabbitAutoConfiguration { ...@@ -109,6 +109,9 @@ public class RabbitAutoConfiguration {
RabbitProperties.Ssl ssl = config.getSsl(); RabbitProperties.Ssl ssl = config.getSsl();
if (ssl.isEnabled()) { if (ssl.isEnabled()) {
factory.setUseSSL(true); factory.setUseSSL(true);
if (ssl.getAlgorithm() != null) {
factory.setSslAlgorithm(ssl.getAlgorithm());
}
factory.setKeyStore(ssl.getKeyStore()); factory.setKeyStore(ssl.getKeyStore());
factory.setKeyStorePassphrase(ssl.getKeyStorePassword()); factory.setKeyStorePassphrase(ssl.getKeyStorePassword());
factory.setTrustStore(ssl.getTrustStore()); factory.setTrustStore(ssl.getTrustStore());
......
...@@ -274,6 +274,12 @@ public class RabbitProperties { ...@@ -274,6 +274,12 @@ public class RabbitProperties {
*/ */
private String trustStorePassword; private String trustStorePassword;
/**
* The SSL algorithm to use (e.g. TLSv1.1). Default is set automatically by the
* rabbit client library.
*/
private String algorithm;
public boolean isEnabled() { public boolean isEnabled() {
return this.enabled; return this.enabled;
} }
...@@ -314,6 +320,14 @@ public class RabbitProperties { ...@@ -314,6 +320,14 @@ public class RabbitProperties {
this.trustStorePassword = trustStorePassword; this.trustStorePassword = trustStorePassword;
} }
public String getAlgorithm() {
return this.algorithm;
}
public void setAlgorithm(String sslAlgorithm) {
this.algorithm = sslAlgorithm;
}
} }
public static class Cache { public static class Cache {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment