update
This commit is contained in:
@@ -342,7 +342,7 @@ NATS.publish(conn, "test.topic", message_envelope_json_str; reply_to="test.reply
|
|||||||
NATS.drain(conn)
|
NATS.drain(conn)
|
||||||
|
|
||||||
# OR using request-reply pattern
|
# OR using request-reply pattern
|
||||||
reply = NATS.request(conn, "test.topic", message_envelope_json_str, timeout=10)
|
reply = NATS.request(conn, "test.topic", message_envelope_json_str; timeout=10)
|
||||||
```
|
```
|
||||||
|
|
||||||
#### Receive Messages (Publish - Subscribe Pattern)
|
#### Receive Messages (Publish - Subscribe Pattern)
|
||||||
|
|||||||
Reference in New Issue
Block a user