From 9edd0fc68db94b2106d38d9516a7e056662a6b4e Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Tue, 23 May 2017 09:06:22 +0200 Subject: [PATCH] zeromq: fix little bug because socket-types were swapped --- lib/nodes/zeromq.c | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/lib/nodes/zeromq.c b/lib/nodes/zeromq.c index a7bb5b877..e86ec04c4 100644 --- a/lib/nodes/zeromq.c +++ b/lib/nodes/zeromq.c @@ -116,9 +116,7 @@ char * zeromq_print(struct node *n) int zeromq_init(struct super_node *sn) { context = zmq_ctx_new(); - - info("context is %p", context); - + return context == NULL; } @@ -134,8 +132,8 @@ int zeromq_start(struct node *n) switch (z->pattern) { case ZEROMQ_PATTERN_RADIODISH: - z->subscriber.socket = zmq_socket(context, ZMQ_RADIO); - z->publisher.socket = zmq_socket(context, ZMQ_DISH); + z->subscriber.socket = zmq_socket(context, ZMQ_DISH); + z->publisher.socket = zmq_socket(context, ZMQ_RADIO); break; case ZEROMQ_PATTERN_PUBSUB: