diff options
| author | Rainer Gerhards <rgerhards@adiscon.com> | 2012-11-01 19:04:37 +0100 |
|---|---|---|
| committer | Rainer Gerhards <rgerhards@adiscon.com> | 2012-11-01 19:04:37 +0100 |
| commit | d18b0a62f82739946c25fcc5610fc98b447771c3 (patch) | |
| tree | c128256b4741c03f532f250031d7ac26a2c928d6 /plugins/imzmq3/imzmq3.c | |
| parent | 581a11a103ff9ad08ab2f08eae7d9a5911d09116 (diff) | |
| parent | d5c033ac2b5c6218c92dbe83d9605ca98da5d397 (diff) | |
| download | rsyslog-d18b0a62f82739946c25fcc5610fc98b447771c3.tar.gz rsyslog-d18b0a62f82739946c25fcc5610fc98b447771c3.tar.bz2 rsyslog-d18b0a62f82739946c25fcc5610fc98b447771c3.zip | |
Merge branch 'v7-stable'
Diffstat (limited to 'plugins/imzmq3/imzmq3.c')
| -rw-r--r-- | plugins/imzmq3/imzmq3.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/imzmq3/imzmq3.c b/plugins/imzmq3/imzmq3.c index dc1d64d3..52c12a53 100644 --- a/plugins/imzmq3/imzmq3.c +++ b/plugins/imzmq3/imzmq3.c @@ -375,8 +375,10 @@ static rsRetVal createSocket(socket_info* info, void** sock) { zsocket_set_rcvhwm(*sock, info->rcvHWM); /* Set subscriptions.*/ - for (ii = 0; ii < sizeof(info->subscriptions)/sizeof(char*); ++ii) - zsocket_set_subscribe(*sock, info->subscriptions[ii]); + if (info->type == ZMQ_SUB) { + for (ii = 0; ii < sizeof(info->subscriptions)/sizeof(char*); ++ii) + zsocket_set_subscribe(*sock, info->subscriptions[ii]); + } |