freddy 0.1.1.0 → 0.1.2.0
raw patch · 2 files changed
+5/−2 lines, 2 files
Files
- freddy.cabal +1/−1
- src/Network/Freddy.hs +4/−1
freddy.cabal view
@@ -1,5 +1,5 @@ name: freddy-version: 0.1.1.0+version: 0.1.2.0 homepage: https://github.com/salemove/freddy-hs license: MIT license-file: LICENSE
src/Network/Freddy.hs view
@@ -195,6 +195,7 @@ AMQP.publishMsg (amqpProduceChannel connection) "" (Request.queueName request) msg AMQP.publishMsg (amqpProduceChannel connection) topicExchange (Request.queueName request) msg+ return () {-| Responds to messages on a given destination. It is useful for messages that@@ -279,7 +280,9 @@ sendReply :: AMQP.Message -> AMQP.Channel -> ResultType -> Payload -> IO () sendReply originalMsg channel resType body = case buildReply originalMsg resType body of- Just (Reply queueName message) -> AMQP.publishMsg channel "" queueName message+ Just (Reply queueName message) -> do+ AMQP.publishMsg channel "" queueName message+ return () Nothing -> putStrLn "Could not reply" buildReply :: AMQP.Message -> ResultType -> Payload -> Maybe Reply