amqp 0.2.9 → 0.3.0

raw patch · 2 files changed

+13/−9 lines, 2 files

Files

Network/AMQP.hs +12/−8
amqp.cabal +1/−1

Network/AMQP.hs view

@@ -734,17 +734,21 @@                 if len >= bytes                     then return buf'                     else recvExact' (bytes-len) buf'-             -         -    -writeFrameSock :: Socket -> Frame -> IO ()    ++++writeFrameSock :: Socket -> Frame -> IO () writeFrameSock sock x = do-    NB.send sock $ toStrict $ runPut $ put x-    return ()-        -    +    f $ toStrict $ runPut $ put x+  where+    f x | BS.length x == 0 = return ()+    f x = do+        sent <- NB.send sock x+        f $ BS.drop sent x++  ------------------------ CHANNEL -----------------------------

amqp.cabal view

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