aboutsummaryrefslogtreecommitdiff
path: root/src/tools/nngcat
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2024-11-03 00:51:15 -0700
committerGarrett D'Amore <garrett@damore.org>2024-11-03 00:58:37 -0700
commitb3fc8a44119d7ab90366a1b92a5e1327ebcb8145 (patch)
tree994c0199184fdea3d56eeb61b252e10733588947 /src/tools/nngcat
parent02ec0b55cbee5de4d0fd688ce0ebddf08178dc98 (diff)
downloadnng-b3fc8a44119d7ab90366a1b92a5e1327ebcb8145.tar.gz
nng-b3fc8a44119d7ab90366a1b92a5e1327ebcb8145.tar.bz2
nng-b3fc8a44119d7ab90366a1b92a5e1327ebcb8145.zip
Replace NNG_OPT_SUB_SUBSCRIBE/UNSUBSCRIBE with functions.
The main purpose is to eliminate the NNI_TYPE_OPAQUE options, by putting these into their own first class, protocol-specific, functions.
Diffstat (limited to 'src/tools/nngcat')
-rw-r--r--src/tools/nngcat/nngcat.c3
1 files changed, 1 insertions, 2 deletions
diff --git a/src/tools/nngcat/nngcat.c b/src/tools/nngcat/nngcat.c
index bdf6823c..da3bd6d6 100644
--- a/src/tools/nngcat/nngcat.c
+++ b/src/tools/nngcat/nngcat.c
@@ -1065,8 +1065,7 @@ main(int ac, char **av)
}
for (struct topic *t = topics; t != NULL; t = t->next) {
- rv = nng_socket_set(
- sock, NNG_OPT_SUB_SUBSCRIBE, t->val, strlen(t->val));
+ rv = nng_sub0_socket_subscribe(sock, t->val, strlen(t->val));
if (rv != 0) {
fatal("Unable to subscribe to topic %s: %s", t->val,
nng_strerror(rv));