Upgrade to the latest openssl

Cargo.toml

@@ -25,9 +25,8 @@ url = "1.2"
 amq-proto = "0.1.0"
 
 [dependencies.openssl]
-version = "0.7.*"
+version = "0.10"
 optional = true
-features = ["tlsv1_1", "tlsv1_2"]
 
 [dev-dependencies]
 # clippy  = "*"

src/amqp_error.rs

@@ -68,8 +68,22 @@ impl From<amq_proto::Error> for AMQPError {
 }
 
 #[cfg(feature = "tls")]
-impl From<openssl::ssl::error::SslError> for AMQPError {
-    fn from(err: openssl::ssl::error::SslError) -> AMQPError {
+impl From<openssl::ssl::Error> for AMQPError {
+    fn from(err: openssl::ssl::Error) -> AMQPError {
+        AMQPError::Protocol(format!("{}", err))
+    }
+}
+
+#[cfg(feature = "tls")]
+impl<T: fmt::Debug> From<openssl::ssl::HandshakeError<T>> for AMQPError {
+    fn from(err: openssl::ssl::HandshakeError<T>) -> AMQPError {
+        AMQPError::Protocol(format!("{}", err))
+    }
+}
+
+#[cfg(feature = "tls")]
+impl From<openssl::error::ErrorStack> for AMQPError {
+    fn from(err: openssl::error::ErrorStack) -> AMQPError {
         AMQPError::Protocol(format!("{}", err))
     }
 }

src/connection.rs

@@ -3,7 +3,7 @@ use std::io::Write;
 use std::cmp;
 
 #[cfg(feature = "tls")]
-use openssl::ssl::{SslContext, SslMethod, SslStream};
+use openssl::ssl::{SslConnector, SslMethod, SslStream};
 
 use amqp_error::AMQPResult;
 use amq_proto::{Frame, FrameType, FramePayload};
@@ -30,10 +30,7 @@ impl Clone for Connection {
             }
             #[cfg(feature = "tls")]
             AMQPStream::Tls(ref stream) => {
-                Connection {
-                    socket: AMQPStream::Tls(stream.try_clone().unwrap()),
-                    frame_max_limit: self.frame_max_limit,
-                }
+                panic!("SslStream cannot be cloned");
             }
         }
     }
@@ -43,8 +40,8 @@ impl Connection {
     #[cfg(feature = "tls")]
     pub fn open_tls(host: &str, port: u16) -> AMQPResult<Connection> {
         let socket = try!(TcpStream::connect((host, port)));
-        let ctx = try!(SslContext::new(SslMethod::Sslv23));
-        let mut tls_socket = try!(SslStream::connect(&ctx, socket));
+        let ctx = SslConnector::builder(SslMethod::tls())?.build();
+        let mut tls_socket = try!(ctx.connect(host, socket));
         try!(init_connection(&mut tls_socket));
         Ok(Connection {
             socket: AMQPStream::Tls(tls_socket),