echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use auto-delete on queue.declare, not passive

Browse Source
This commit is contained in:
Michael Klishin 2013-10-06 22:48:17 +04:00
parent d9cfbf1600
commit d33ae6d809
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
haskell/receive.hs
View File

@ -8,9 +8,9 @@ main = do
conn <- openConnection "127.0.0.1" "/" "guest" "guest"
ch <- openChannel conn
declareQueue ch newQueue {queueName = "hello",
queuePassive = False,
queueDurable = False}
declareQueue ch newQueue {queueName = "hello",
queueAutoDelete = False,
queueDurable = False}
putStrLn " [*] Waiting for messages. to Exit press CTRL+C"
consumeMsgs ch "hello" NoAck deliveryHandler

6
haskell/send.hs
View File

@ -8,9 +8,9 @@ main = do
conn <- openConnection "127.0.0.1" "/" "guest" "guest"
ch <- openChannel conn
declareQueue ch newQueue {queueName = "hello",
queuePassive = False,
queueDurable = False}
declareQueue ch newQueue {queueName = "hello",
queueAutoDelete = False,
queueDurable = False}
publishMsg ch "" "hello"
(newMsg {msgBody = (BL.pack "Hello World!"),