diff --git a/snaplet-amqp.cabal b/snaplet-amqp.cabal
--- a/snaplet-amqp.cabal
+++ b/snaplet-amqp.cabal
@@ -1,5 +1,5 @@
 Name:                snaplet-amqp
-Version:             0.1.3.0
+Version:             0.1.3.1
 Synopsis:            Snap framework snaplet for the AMQP library
 Homepage:            https://github.com/ixmatus/snaplet-amqp
 License:             BSD3
diff --git a/src/Snap/Snaplet/AMQP.hs b/src/Snap/Snaplet/AMQP.hs
--- a/src/Snap/Snaplet/AMQP.hs
+++ b/src/Snap/Snaplet/AMQP.hs
@@ -1,8 +1,9 @@
-{-# LANGUAGE ConstraintKinds   #-}
-{-# LANGUAGE FlexibleContexts  #-}
-{-# LANGUAGE FlexibleInstances #-}
-{-# LANGUAGE OverloadedStrings #-}
-{-# LANGUAGE TypeFamilies      #-}
+{-# LANGUAGE ConstraintKinds     #-}
+{-# LANGUAGE FlexibleContexts    #-}
+{-# LANGUAGE FlexibleInstances   #-}
+{-# LANGUAGE OverloadedStrings   #-}
+{-# LANGUAGE ScopedTypeVariables #-}
+{-# LANGUAGE TypeFamilies        #-}
 
 module Snap.Snaplet.AMQP
   ( initAMQP
@@ -17,9 +18,10 @@
 import           Data.Configurator
 import           Data.Configurator.Types
 import           Network.AMQP               (Channel, Connection,
-                                             closeConnection, openChannel,
-                                             openConnection')
-import           Network.Socket             (PortNumber (..))
+                                             ConnectionOpts (..),
+                                             closeConnection,
+                                             defaultConnectionOpts, openChannel,
+                                             openConnection'', plain)
 import           Paths_snaplet_amqp
 import           Snap.Snaplet
 
@@ -68,7 +70,13 @@
   login <- liftIO $ require conf "login"
   pass  <- liftIO $ require conf "password"
 
-  conn  <- liftIO $ openConnection' host (PortNum port) vhost login pass
+  let connOpts = defaultConnectionOpts
+                   { coServers = [(host, (fromInteger port))]
+                   , coVHost   = vhost
+                   , coAuth    = [plain login pass]
+                   }
+
+  conn  <- liftIO $ openConnection'' connOpts
   chan  <- liftIO $ openChannel conn
 
   return (conn, chan)