-
Notifications
You must be signed in to change notification settings - Fork 4
/
js_mgmt.tcl
68 lines (52 loc) · 3.26 KB
/
js_mgmt.tcl
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
# EXAMPLE #6: JetStream management: streams and consumers
# remember to start nats-server with -js to enable JetStream and -sd to set the storage directory
package require nats
package require fileutil
package require logger::utils
# the default logger of nats::connection can't change logging level dynamically, so let's use the logger package
set natsLogger [logger::init nats]
logger::utils::applyAppender -appender console -service nats -appenderArgs {-conversionPattern {\[[nats::timestamp] %c %p\] %m}}
${natsLogger}::setlevel warn
set conn [nats::connection new "JS_mgmt" -logger $natsLogger]
$conn configure -servers nats://localhost:4222
$conn connect
# NATS CLI has a very useful option --trace that allows to see JSON requests and replies from JetStream API.
# It is useful for troubleshooting and better understanding of NATS
# nats-tcl provides it as well; when enabled, it will print to the debug logger
set js [$conn jet_stream -trace 1]
puts "Enabling debug logging ..."
${natsLogger}::setlevel debug
# create a stream collecting messages sent to the foo.* and bar.* subjects - this request will be traced
$js add_stream MY_STREAM -subjects [list foo.* bar.*] -retention limits -max_msgs 100 -discard old
${natsLogger}::setlevel warn
puts "Disabled debug logging"
# Create another stream with configuration from a JSON file (compatible with NATS CLI)
set json_config [fileutil::cat [file join [file dirname [info script]] stream_config.json]]
set response [$js add_stream_from_json $json_config]
puts "Added a stream: $response" ;# unlike add_stream that returns a Tcl dict, add_stream_from_json returns JSON exactly as received from NATS
puts "List all streams: [$js stream_names]"
puts "Find the stream that listens to foo.* : [$js stream_names -subject foo.*]"
puts "Info about MY_STREAM: [$js stream_info MY_STREAM]"
# create a push consumer using a config from Tcl dict
# note that dashes in option names are optional, i.e. you can use 'description' or '-description' etc
set push_consumer_config [dict create \
description "dummy push consumer" \
filter_subject bar.*]
set response [$js add_push_consumer MY_STREAM PUSH_CONSUMER my_delivery_subj {*}$push_consumer_config]
puts "Added a push consumer: $response"
# Create a pull consumer with configuration from a JSON file (compatible with NATS CLI)
set json_config [fileutil::cat [file join [file dirname [info script]] pull_consumer_config.json]]
set response [$js add_consumer_from_json MY_STREAM PULL_CONSUMER $json_config]
puts "Added a pull consumer: $response"
# Note: while you can use the universal method 'add_consumer' that can create both push and pull consumers,
# using explicit 'add_push_consumer' and 'add_pull_consumer' allows cleaner code
puts "List all consumers defined on MY_STREAM: [$js consumer_names MY_STREAM]"
set response [$js delete_consumer MY_STREAM PUSH_CONSUMER]
puts "Deleted PUSH_CONSUMER: $response"
puts "Check that there is only one consumer left: [$js consumer_names MY_STREAM]"
$js delete_stream MY_STREAM
$js delete_stream MY_STREAM2
$js destroy
$conn destroy
puts "Done! Remember to delete the NATS storage before running the example again"
# not all JetStream management functions are shown in this example! refer to the API docs and tests for more details