amqp 0.15.1 → 0.16.0

raw patch · 4 files changed

+11/−5 lines, 4 filesPVP ok

version bump matches the API change (PVP)

API changes (from Hackage documentation)

+ Network.AMQP: [coName] :: ConnectionOpts -> !(Maybe Text)

- Network.AMQP: ConnectionOpts :: ![(String, PortNumber)] -> !Text -> ![SASLMechanism] -> !(Maybe Word32) -> !(Maybe Word16) -> !(Maybe Word16) -> Maybe TLSSettings -> ConnectionOpts

+ Network.AMQP: ConnectionOpts :: ![(String, PortNumber)] -> !Text -> ![SASLMechanism] -> !(Maybe Word32) -> !(Maybe Word16) -> !(Maybe Word16) -> Maybe TLSSettings -> !(Maybe Text) -> ConnectionOpts

Files

Network/AMQP.hs +1/−1
Network/AMQP/Internal.hs +5/−3
amqp.cabal +1/−1
changelog.md +4/−0

Network/AMQP.hs view

@@ -599,7 +599,7 @@ --     * no limit on the number of used channels
 --
 defaultConnectionOpts :: ConnectionOpts
-defaultConnectionOpts = ConnectionOpts [("localhost", 5672)] "/" [plain "guest" "guest"] (Just 131072) Nothing Nothing Nothing
+defaultConnectionOpts = ConnectionOpts [("localhost", 5672)] "/" [plain "guest" "guest"] (Just 131072) Nothing Nothing Nothing Nothing
 
 -- | @openConnection hostname virtualHost loginName loginPassword@ opens a connection to an AMQP server running on @hostname@.
 -- @virtualHost@ is used as a namespace for AMQP resources (default is \"/\"), so different applications could use multiple virtual hosts on the same AMQP server.

Network/AMQP/Internal.hs view

@@ -162,7 +162,8 @@                             coMaxFrameSize :: !(Maybe Word32), -- ^ The maximum frame size to be used. If not specified, no limit is assumed.
                             coHeartbeatDelay :: !(Maybe Word16), -- ^ The delay in seconds, after which the client expects a heartbeat frame from the broker. If 'Nothing', the value suggested by the broker is used. Use @Just 0@ to disable the heartbeat mechnism.
                             coMaxChannel :: !(Maybe Word16), -- ^ The maximum number of channels the client will use.
-                            coTLSSettings :: Maybe TLSSettings -- ^ Whether or not to connect to servers using TLS. See http://www.rabbitmq.com/ssl.html for details.
+                            coTLSSettings :: Maybe TLSSettings, -- ^ Whether or not to connect to servers using TLS. See http://www.rabbitmq.com/ssl.html for details.
+                            coName :: !(Maybe Text) -- ^ optional connection name (will be displayed in the RabbitMQ web interface)
                         }
 -- | Represents the kind of TLS connection to establish.
 data TLSSettings =
@@ -326,8 +327,9 @@                                              (ShortString $ saslName sasl)
                                              (LongString $ saslInitialResponse sasl)
                                              (ShortString "en_US")) ))
-                    where clientProperties = FieldTable $ M.fromList [ ("platform", FVString "Haskell")
-                                                                     , ("version" , FVString . T.pack $ showVersion version)]
+                    where clientProperties = FieldTable $ M.fromList $ [ ("platform", FVString "Haskell")
+                                                                       , ("version" , FVString . T.pack $ showVersion version)
+                                                                       ] ++ maybe [] (\x -> [("connection_name", FVString x)]) (coName connOpts)
 
     handleSecureUntilTune handle sasl = do
         tuneOrSecure <- readFrame handle

amqp.cabal view

@@ -1,5 +1,5 @@ Name:                amqp
-Version:             0.15.1
+Version:             0.16.0
 Synopsis:            Client library for AMQP servers (currently only RabbitMQ)
 Description:         Client library for AMQP servers (currently only RabbitMQ)
 License:             BSD3

changelog.md view

@@ -1,3 +1,7 @@+### Version 0.16.0
+
+* new `coName` field in `ConnectionOpts` to specify a custom name that will be displayed in the RabbitMQ web interface
+
 ### Version 0.15.1
 
 * export the `AckType` data-type and constructors