Skip to content

Commit d33ae6d

Browse files
Use auto-delete on queue.declare, not passive
1 parent d9cfbf1 commit d33ae6d

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

haskell/receive.hs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,9 @@ main = do
88
conn <- openConnection "127.0.0.1" "/" "guest" "guest"
99
ch <- openChannel conn
1010

11-
declareQueue ch newQueue {queueName = "hello",
12-
queuePassive = False,
13-
queueDurable = False}
11+
declareQueue ch newQueue {queueName = "hello",
12+
queueAutoDelete = False,
13+
queueDurable = False}
1414

1515
putStrLn " [*] Waiting for messages. to Exit press CTRL+C"
1616
consumeMsgs ch "hello" NoAck deliveryHandler

haskell/send.hs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,9 @@ main = do
88
conn <- openConnection "127.0.0.1" "/" "guest" "guest"
99
ch <- openChannel conn
1010

11-
declareQueue ch newQueue {queueName = "hello",
12-
queuePassive = False,
13-
queueDurable = False}
11+
declareQueue ch newQueue {queueName = "hello",
12+
queueAutoDelete = False,
13+
queueDurable = False}
1414

1515
publishMsg ch "" "hello"
1616
(newMsg {msgBody = (BL.pack "Hello World!"),

0 commit comments

Comments
 (0)