amqp 0.13.0 → 0.13.1

raw patch · 3 files changed

+89/−3 lines, 3 filesPVP: major bump suggested

API removals or changes: PVP suggests a major version bump

API changes (from Hackage documentation)

- Network.AMQP: coAuth :: ConnectionOpts -> ![SASLMechanism]

- Network.AMQP: coHeartbeatDelay :: ConnectionOpts -> !(Maybe Word16)

- Network.AMQP: coMaxChannel :: ConnectionOpts -> !(Maybe Word16)

- Network.AMQP: coMaxFrameSize :: ConnectionOpts -> !(Maybe Word32)

- Network.AMQP: coServers :: ConnectionOpts -> ![(String, PortNumber)]

- Network.AMQP: coTLSSettings :: ConnectionOpts -> Maybe TLSSettings

- Network.AMQP: coVHost :: ConnectionOpts -> !Text

- Network.AMQP: envChannel :: Envelope -> Channel

- Network.AMQP: envDeliveryTag :: Envelope -> LongLongInt

- Network.AMQP: envExchangeName :: Envelope -> Text

- Network.AMQP: envRedelivered :: Envelope -> Bool

- Network.AMQP: envRoutingKey :: Envelope -> Text

- Network.AMQP: errExchange :: PublishError -> Maybe Text

- Network.AMQP: errReplyCode :: PublishError -> ReturnReplyCode

- Network.AMQP: errRoutingKey :: PublishError -> Text

- Network.AMQP: exchangeArguments :: ExchangeOpts -> FieldTable

- Network.AMQP: exchangeAutoDelete :: ExchangeOpts -> Bool

- Network.AMQP: exchangeDurable :: ExchangeOpts -> Bool

- Network.AMQP: exchangeInternal :: ExchangeOpts -> Bool

- Network.AMQP: exchangeName :: ExchangeOpts -> Text

- Network.AMQP: exchangePassive :: ExchangeOpts -> Bool

- Network.AMQP: exchangeType :: ExchangeOpts -> Text

- Network.AMQP: instance Eq Ack

- Network.AMQP: instance Eq ExchangeOpts

- Network.AMQP: instance Eq QueueOpts

- Network.AMQP: instance Ord Ack

- Network.AMQP: instance Ord ExchangeOpts

- Network.AMQP: instance Ord QueueOpts

- Network.AMQP: instance Read Ack

- Network.AMQP: instance Read ExchangeOpts

- Network.AMQP: instance Read QueueOpts

- Network.AMQP: instance Show Ack

- Network.AMQP: instance Show ExchangeOpts

- Network.AMQP: instance Show QueueOpts

- Network.AMQP: msgApplicationID :: Message -> Maybe Text

- Network.AMQP: msgBody :: Message -> ByteString

- Network.AMQP: msgClusterID :: Message -> Maybe Text

- Network.AMQP: msgContentEncoding :: Message -> Maybe Text

- Network.AMQP: msgContentType :: Message -> Maybe Text

- Network.AMQP: msgCorrelationID :: Message -> Maybe Text

- Network.AMQP: msgDeliveryMode :: Message -> Maybe DeliveryMode

- Network.AMQP: msgExpiration :: Message -> Maybe Text

- Network.AMQP: msgHeaders :: Message -> Maybe FieldTable

- Network.AMQP: msgID :: Message -> Maybe Text

- Network.AMQP: msgPriority :: Message -> Maybe Octet

- Network.AMQP: msgReplyTo :: Message -> Maybe Text

- Network.AMQP: msgTimestamp :: Message -> Maybe Timestamp

- Network.AMQP: msgType :: Message -> Maybe Text

- Network.AMQP: msgUserID :: Message -> Maybe Text

- Network.AMQP: queueAutoDelete :: QueueOpts -> Bool

- Network.AMQP: queueDurable :: QueueOpts -> Bool

- Network.AMQP: queueExclusive :: QueueOpts -> Bool

- Network.AMQP: queueHeaders :: QueueOpts -> FieldTable

- Network.AMQP: queueName :: QueueOpts -> Text

- Network.AMQP: queuePassive :: QueueOpts -> Bool

- Network.AMQP: saslChallengeFunc :: SASLMechanism -> !(Maybe (ByteString -> IO ByteString))

- Network.AMQP: saslInitialResponse :: SASLMechanism -> !ByteString

- Network.AMQP: saslName :: SASLMechanism -> !Text

- Network.AMQP.Types: instance Binary DecimalValue

- Network.AMQP.Types: instance Binary FieldTable

- Network.AMQP.Types: instance Binary FieldValue

- Network.AMQP.Types: instance Binary LongString

- Network.AMQP.Types: instance Binary ShortString

- Network.AMQP.Types: instance Eq AMQPException

- Network.AMQP.Types: instance Eq DecimalValue

- Network.AMQP.Types: instance Eq FieldTable

- Network.AMQP.Types: instance Eq FieldValue

- Network.AMQP.Types: instance Eq LongString

- Network.AMQP.Types: instance Eq ShortString

- Network.AMQP.Types: instance Exception AMQPException

- Network.AMQP.Types: instance Ord AMQPException

- Network.AMQP.Types: instance Ord DecimalValue

- Network.AMQP.Types: instance Ord FieldTable

- Network.AMQP.Types: instance Ord FieldValue

- Network.AMQP.Types: instance Ord LongString

- Network.AMQP.Types: instance Ord ShortString

- Network.AMQP.Types: instance Read DecimalValue

- Network.AMQP.Types: instance Read FieldTable

- Network.AMQP.Types: instance Read FieldValue

- Network.AMQP.Types: instance Read LongString

- Network.AMQP.Types: instance Read ShortString

- Network.AMQP.Types: instance Show AMQPException

- Network.AMQP.Types: instance Show ConfirmationResult

- Network.AMQP.Types: instance Show DecimalValue

- Network.AMQP.Types: instance Show FieldTable

- Network.AMQP.Types: instance Show FieldValue

- Network.AMQP.Types: instance Show LongString

- Network.AMQP.Types: instance Show ShortString

- Network.AMQP.Types: instance Typeable AMQPException

+ Network.AMQP: [coAuth] :: ConnectionOpts -> ![SASLMechanism]

+ Network.AMQP: [coHeartbeatDelay] :: ConnectionOpts -> !(Maybe Word16)

+ Network.AMQP: [coMaxChannel] :: ConnectionOpts -> !(Maybe Word16)

+ Network.AMQP: [coMaxFrameSize] :: ConnectionOpts -> !(Maybe Word32)

+ Network.AMQP: [coServers] :: ConnectionOpts -> ![(String, PortNumber)]

+ Network.AMQP: [coTLSSettings] :: ConnectionOpts -> Maybe TLSSettings

+ Network.AMQP: [coVHost] :: ConnectionOpts -> !Text

+ Network.AMQP: [envChannel] :: Envelope -> Channel

+ Network.AMQP: [envDeliveryTag] :: Envelope -> LongLongInt

+ Network.AMQP: [envExchangeName] :: Envelope -> Text

+ Network.AMQP: [envRedelivered] :: Envelope -> Bool

+ Network.AMQP: [envRoutingKey] :: Envelope -> Text

+ Network.AMQP: [errExchange] :: PublishError -> Maybe Text

+ Network.AMQP: [errReplyCode] :: PublishError -> ReturnReplyCode

+ Network.AMQP: [errRoutingKey] :: PublishError -> Text

+ Network.AMQP: [exchangeArguments] :: ExchangeOpts -> FieldTable

+ Network.AMQP: [exchangeAutoDelete] :: ExchangeOpts -> Bool

+ Network.AMQP: [exchangeDurable] :: ExchangeOpts -> Bool

+ Network.AMQP: [exchangeInternal] :: ExchangeOpts -> Bool

+ Network.AMQP: [exchangeName] :: ExchangeOpts -> Text

+ Network.AMQP: [exchangePassive] :: ExchangeOpts -> Bool

+ Network.AMQP: [exchangeType] :: ExchangeOpts -> Text

+ Network.AMQP: [msgApplicationID] :: Message -> Maybe Text

+ Network.AMQP: [msgBody] :: Message -> ByteString

+ Network.AMQP: [msgClusterID] :: Message -> Maybe Text

+ Network.AMQP: [msgContentEncoding] :: Message -> Maybe Text

+ Network.AMQP: [msgContentType] :: Message -> Maybe Text

+ Network.AMQP: [msgCorrelationID] :: Message -> Maybe Text

+ Network.AMQP: [msgDeliveryMode] :: Message -> Maybe DeliveryMode

+ Network.AMQP: [msgExpiration] :: Message -> Maybe Text

+ Network.AMQP: [msgHeaders] :: Message -> Maybe FieldTable

+ Network.AMQP: [msgID] :: Message -> Maybe Text

+ Network.AMQP: [msgPriority] :: Message -> Maybe Octet

+ Network.AMQP: [msgReplyTo] :: Message -> Maybe Text

+ Network.AMQP: [msgTimestamp] :: Message -> Maybe Timestamp

+ Network.AMQP: [msgType] :: Message -> Maybe Text

+ Network.AMQP: [msgUserID] :: Message -> Maybe Text

+ Network.AMQP: [queueAutoDelete] :: QueueOpts -> Bool

+ Network.AMQP: [queueDurable] :: QueueOpts -> Bool

+ Network.AMQP: [queueExclusive] :: QueueOpts -> Bool

+ Network.AMQP: [queueHeaders] :: QueueOpts -> FieldTable

+ Network.AMQP: [queueName] :: QueueOpts -> Text

+ Network.AMQP: [queuePassive] :: QueueOpts -> Bool

+ Network.AMQP: [saslChallengeFunc] :: SASLMechanism -> !(Maybe (ByteString -> IO ByteString))

+ Network.AMQP: [saslInitialResponse] :: SASLMechanism -> !ByteString

+ Network.AMQP: [saslName] :: SASLMechanism -> !Text

+ Network.AMQP: instance GHC.Classes.Eq Network.AMQP.Ack

+ Network.AMQP: instance GHC.Classes.Eq Network.AMQP.ExchangeOpts

+ Network.AMQP: instance GHC.Classes.Eq Network.AMQP.QueueOpts

+ Network.AMQP: instance GHC.Classes.Ord Network.AMQP.Ack

+ Network.AMQP: instance GHC.Classes.Ord Network.AMQP.ExchangeOpts

+ Network.AMQP: instance GHC.Classes.Ord Network.AMQP.QueueOpts

+ Network.AMQP: instance GHC.Read.Read Network.AMQP.Ack

+ Network.AMQP: instance GHC.Read.Read Network.AMQP.ExchangeOpts

+ Network.AMQP: instance GHC.Read.Read Network.AMQP.QueueOpts

+ Network.AMQP: instance GHC.Show.Show Network.AMQP.Ack

+ Network.AMQP: instance GHC.Show.Show Network.AMQP.ExchangeOpts

+ Network.AMQP: instance GHC.Show.Show Network.AMQP.QueueOpts

+ Network.AMQP.Types: instance Data.Binary.Class.Binary Network.AMQP.Types.DecimalValue

+ Network.AMQP.Types: instance Data.Binary.Class.Binary Network.AMQP.Types.FieldTable

+ Network.AMQP.Types: instance Data.Binary.Class.Binary Network.AMQP.Types.FieldValue

+ Network.AMQP.Types: instance Data.Binary.Class.Binary Network.AMQP.Types.LongString

+ Network.AMQP.Types: instance Data.Binary.Class.Binary Network.AMQP.Types.ShortString

+ Network.AMQP.Types: instance GHC.Classes.Eq Network.AMQP.Types.AMQPException

+ Network.AMQP.Types: instance GHC.Classes.Eq Network.AMQP.Types.DecimalValue

+ Network.AMQP.Types: instance GHC.Classes.Eq Network.AMQP.Types.FieldTable

+ Network.AMQP.Types: instance GHC.Classes.Eq Network.AMQP.Types.FieldValue

+ Network.AMQP.Types: instance GHC.Classes.Eq Network.AMQP.Types.LongString

+ Network.AMQP.Types: instance GHC.Classes.Eq Network.AMQP.Types.ShortString

+ Network.AMQP.Types: instance GHC.Classes.Ord Network.AMQP.Types.AMQPException

+ Network.AMQP.Types: instance GHC.Classes.Ord Network.AMQP.Types.DecimalValue

+ Network.AMQP.Types: instance GHC.Classes.Ord Network.AMQP.Types.FieldTable

+ Network.AMQP.Types: instance GHC.Classes.Ord Network.AMQP.Types.FieldValue

+ Network.AMQP.Types: instance GHC.Classes.Ord Network.AMQP.Types.LongString

+ Network.AMQP.Types: instance GHC.Classes.Ord Network.AMQP.Types.ShortString

+ Network.AMQP.Types: instance GHC.Exception.Exception Network.AMQP.Types.AMQPException

+ Network.AMQP.Types: instance GHC.Read.Read Network.AMQP.Types.DecimalValue

+ Network.AMQP.Types: instance GHC.Read.Read Network.AMQP.Types.FieldTable

+ Network.AMQP.Types: instance GHC.Read.Read Network.AMQP.Types.FieldValue

+ Network.AMQP.Types: instance GHC.Read.Read Network.AMQP.Types.LongString

+ Network.AMQP.Types: instance GHC.Read.Read Network.AMQP.Types.ShortString

+ Network.AMQP.Types: instance GHC.Show.Show Network.AMQP.Types.AMQPException

+ Network.AMQP.Types: instance GHC.Show.Show Network.AMQP.Types.ConfirmationResult

+ Network.AMQP.Types: instance GHC.Show.Show Network.AMQP.Types.DecimalValue

+ Network.AMQP.Types: instance GHC.Show.Show Network.AMQP.Types.FieldTable

+ Network.AMQP.Types: instance GHC.Show.Show Network.AMQP.Types.FieldValue

+ Network.AMQP.Types: instance GHC.Show.Show Network.AMQP.Types.LongString

+ Network.AMQP.Types: instance GHC.Show.Show Network.AMQP.Types.ShortString

Files

Network/AMQP/Internal.hs +0/−1
amqp.cabal +3/−2
changelog.md +86/−0

Network/AMQP/Internal.hs view

@@ -308,7 +308,6 @@                               })
         either
             (\(ex :: CE.SomeException) -> do
-                hPutStrLn stderr $ "Error connecting to "++show (host, port)++": "++show ex
                 connect rest)
             (return)
             result

amqp.cabal view

@@ -1,5 +1,5 @@ Name:                amqp
-Version:             0.13.0
+Version:             0.13.1
 Synopsis:            Client library for AMQP servers (currently only RabbitMQ)
 Description:         Client library for AMQP servers (currently only RabbitMQ)
                      .
@@ -15,7 +15,8 @@ bug-reports:         https://github.com/hreinhardt/amqp/issues
 Cabal-Version:       >=1.8
 Extra-source-files:  examples/ExampleConsumer.hs,
-                     examples/ExampleProducer.hs
+                     examples/ExampleProducer.hs,
+                     changelog.md
 
 flag network-uri
    description: Get Network.URI from the network-uri package

+ changelog.md view

@@ -0,0 +1,86 @@+### Version 0.13.1
+
+* don't print to stderr when `openConnection` fails to connect to a broker
+
+### Version 0.13.0
+
+* support for [RabbitMQ publisher confirms](http://www.rabbitmq.com/confirms.html)
+
+### Version 0.12.3
+
+* send version info of this library to RabbitMQ on connecting
+
+### Version 0.12.2
+
+* GHC 7.10 compatibility
+
+### Version 0.12.1
+
+* error messages now go to stderr
+
+### Version 0.12.0
+
+* new function addChannelExceptionHandler
+
+### Version 0.11.0
+
+* all content fields for messages are now supported
+
+### Version 0.10.0
+
+* the maximum number of channels can now be set
+
+### Version 0.9.0
+
+* add 'global' flag for qos
+
+### Version 0.8.3
+
+* implement closeChannel
+
+### Version 0.8.0
+
+* TLS support
+* new helper function rejectEnv
+* new field exchangeArguments in ExchangeOpts
+* new module Network.AMQP.Lifted with consumeMsgs functions lifted to MonadBaseControl
+
+### Version 0.7.0
+
+* new function fromURI to parse AMQP URIs
+* heartbeat support
+
+### Version 0.6.0
+
+* new function addReturnListener which allows specifying a handler for returned messages
+* new function openConnection'' with support for most AMQP connection options
+* better error message on failed connection handshake
+
+### Version 0.5.0
+
+* support for AMQP 0-9-1
+* new function consumeMsgs' which allows you to pass in a field-table
+* new function bindExchange allows for binding an exchange to another exchange
+* new function unbindQueue allows unbinding a queue from an exchange
+* new function unbindExchange allows unbinding an exchange from an exchange
+
+### Version 0.4.3
+
+* use Handles instead of sockets 
+* fix deprecation warnings from Data.Binary
+
+### Version 0.4.2
+
+* add (Read, Ord, Eq, Show) instances for most data-types
+
+### Version 0.4.1
+
+* add queueHeaders field to QueueOpts
+
+### Version 0.4
+
+* Data.Text is now used instead of Strings. Using the _OverloadedStrings_ extension will make upgrading easier
+* the field-types in Network.AMQP.Types should now be more compatible with RabbitMQ
+* hostnames passed to openConnection will now be resolved
+* basic QoS support
+* exceptions thrown in a callback will not erroneously close the channel anymore