snaplet-amqp 0.1.3.0 → 0.1.3.1

raw patch · 2 files changed

+18/−10 lines, 2 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

Files

• snaplet-amqp.cabal +1/−1
• src/Snap/Snaplet/AMQP.hs +17/−9

@@ -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

@@ -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)