connection timeout

diff --git a/Network/AMQP/Utils/Connection.hs b/Network/AMQP/Utils/Connection.hs
index 2cde3774fcd8c6c8043adf5926beafd357d21236..1fd802a65b08fc5b983afde123e81b7aaad8ad2c 100644 (file)
--- a/Network/AMQP/Utils/Connection.hs
+++ b/Network/AMQP/Utils/Connection.hs
@@ -11,6 +11,7 @@ import Network.AMQP.Utils.Options
 import qualified Network.Connection as N
 import Network.TLS
 import Network.TLS.Extra
+import qualified System.Timeout as O
 import System.X509
 
 -- | opens a connection and a channel
@@ -33,7 +34,8 @@ connect args = do
             , clientHooks =
                 def {onCertificateRequest = myCert (cert args) (key args)}
             }
-  conn <-
+  Just conn <-
+    O.timeout to $
     openConnection''
       defaultConnectionOpts
         { coAuth =
@@ -49,8 +51,10 @@ connect args = do
         , coHeartbeatDelay = fmap fromIntegral $ heartBeat args
         , coName = fmap T.pack $ connectionName args
         }
-  chan <- openChannel conn
+  Just chan <- O.timeout to $ openChannel conn
   return (conn, chan)
+  where
+    to = 60000000
 
 --  addChannelExceptionHandler chan
 --                             (\exception -> closeConnection conn >>