From 73866a4c527cbdf726c5fd824526d5657d0e15ee Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 15 六月 2020 19:47:13 +0800
Subject: [PATCH] update
---
test/nanomsg/pubsub.c | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/test/nanomsg/pubsub.c b/test/nanomsg/pubsub.c
index a8f2702..048d221 100644
--- a/test/nanomsg/pubsub.c
+++ b/test/nanomsg/pubsub.c
@@ -6,6 +6,7 @@
#include <nanomsg/nn.h>
#include <nanomsg/pubsub.h>
+#include <nanomsg/reqrep.h>
#define SERVER "server"
#define CLIENT "client"
@@ -31,7 +32,7 @@
{
int sock;
- if ((sock = nn_socket(AF_SP, NN_PUB)) < 0) {
+ if ((sock = nn_socket(AF_SP, NN_REQ )) < 0) {
fatal("nn_socket");
}
if (nn_bind(sock, url) < 0) {
@@ -54,14 +55,14 @@
{
int sock;
- if ((sock = nn_socket(AF_SP, NN_SUB)) < 0) {
+ if ((sock = nn_socket(AF_SP, NN_REP)) < 0) {
fatal("nn_socket");
}
// subscribe to everything ("" means all topics)
- if (nn_setsockopt(sock, NN_SUB, NN_SUB_SUBSCRIBE, "", 0) < 0) {
- fatal("nn_setsockopt");
- }
+ // if (nn_setsockopt(sock, NN_SUB, NN_SUB_SUBSCRIBE, "sjhdfjsdfh", 0) < 0) {
+ // fatal("nn_setsockopt");
+ // }
if (nn_connect(sock, url) < 0) {
fatal("nn_connet");
}
--
Gitblit v1.8.0