Add AMQP Config for SSL protocol

joneyin · Nov 29, 2016 · 2143fbf · 2143fbf
1 parent a2a20e8
commit 2143fbf
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/amqp/src/main/scala/akka/stream/alpakka/amqp/AmqpConnector.scala b/amqp/src/main/scala/akka/stream/alpakka/amqp/AmqpConnector.scala
@@ -15,15 +15,15 @@ private[amqp] trait AmqpConnector {
     val factory = new ConnectionFactory
     settings match {
       case AmqpConnectionUri(uri) => factory.setUri(uri)
-      case AmqpConnectionDetails(host, port, maybeCredentials, maybeVirtualHost) =>
+      case AmqpConnectionDetails(host, port, maybeCredentials, maybeVirtualHost, sslProtocol) =>
         factory.setHost(host)
         factory.setPort(port)
         maybeCredentials.foreach { credentials =>
           factory.setUsername(credentials.username)
           factory.setPassword(credentials.password)
         }
         maybeVirtualHost.foreach(factory.setVirtualHost)
-
+        sslProtocol.foreach(factory.useSslProtocol)
       case DefaultAmqpConnection => // leave it be as is
     }
     factory

diff --git a/amqp/src/main/scala/akka/stream/alpakka/amqp/model.scala b/amqp/src/main/scala/akka/stream/alpakka/amqp/model.scala
@@ -124,7 +124,8 @@ final case class AmqpConnectionDetails(
     host: String,
     port: Int,
     credentials: Option[AmqpCredentials] = None,
-    virtualHost: Option[String] = None
+    virtualHost: Option[String] = None,
+    sslProtocol: Option[String] = None
 ) extends AmqpConnectionSettings {}
 
 object AmqpConnectionDetails {