ton/GeneralUtils
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
tonaerospace
2025-07-23 07:10:28 +07:00
parent 066d72553f
commit 13fcf06503
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
codesnippet/nats.jl
View File

@@ -2,7 +2,7 @@
using NATS, JSON3 using NATS, JSON3
connection = NATS.connect("nats.yiem.cc:4222") connection = NATS.connect("nats.yiem.cc:4222")
sub1 = NATS.reply(connection, "some_subject"; queue_group="group1") do msg 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(payload)
println(msg.reply_to) println(msg.reply_to)
# publish(connection, msg.reply_to, "ACK") # publish(connection, msg.reply_to, "ACK")
@@ -71,7 +71,7 @@ outgoingMsg = Dict(
) )
# may be I can't use NATS request inside NATS reply?? # 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))