diff --git a/amqp-worker.cabal b/amqp-worker.cabal
--- a/amqp-worker.cabal
+++ b/amqp-worker.cabal
@@ -2,7 +2,7 @@
 -- documentation, see http://haskell.org/cabal/users-guide/
 
 name:                amqp-worker
-version:             0.2.4
+version:             0.2.5
 synopsis:            High level functions for working with message queues
 description:         High level functions for working with message queues
 license:             BSD3
diff --git a/src/Network/AMQP/Worker/Connection.hs b/src/Network/AMQP/Worker/Connection.hs
--- a/src/Network/AMQP/Worker/Connection.hs
+++ b/src/Network/AMQP/Worker/Connection.hs
@@ -54,7 +54,7 @@
       chan <- catch (AMQP.openChannel conn) (createEx cvar)
       return chan
 
-    createEx cvar (ConnectionClosedException _) = do
+    createEx cvar (ConnectionClosedException _ _) = do
       reopenConnection cvar
       create cvar