diff --git a/codesnippet/nats.jl b/codesnippet/nats.jl index 26968f6..1df3438 100644 --- a/codesnippet/nats.jl +++ b/codesnippet/nats.jl @@ -2,7 +2,7 @@ using NATS, JSON3 connection = NATS.connect("nats.yiem.cc:4222") sub1 = NATS.reply(connection, "some_subject"; queue_group="group1") do msg - payload = JSON3.read(msg.payload) + payload = copy(JSON3.read(msg.payload)) println(payload) println(msg.reply_to) # publish(connection, msg.reply_to, "ACK") @@ -71,7 +71,7 @@ outgoingMsg = Dict( ) # may be I can't use NATS request inside NATS reply?? -_ = NATS.request(String, connection, msgMeta[:sendTopic], JSON3.write(outgoingMsg); timer=Timer(10)) +r = NATS.request(String, connection, msgMeta[:sendTopic], JSON3.write(outgoingMsg); timer=Timer(10))