diff options
Diffstat (limited to 'plugins')
| -rw-r--r-- | plugins/imzmq3/imzmq3.c | 6 | ||||
| -rw-r--r-- | plugins/mmnormalize/mmnormalize.c | 2 |
2 files changed, 5 insertions, 3 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]); + } diff --git a/plugins/mmnormalize/mmnormalize.c b/plugins/mmnormalize/mmnormalize.c index 9c7718b7..1aef98eb 100644 --- a/plugins/mmnormalize/mmnormalize.c +++ b/plugins/mmnormalize/mmnormalize.c @@ -72,7 +72,7 @@ typedef struct _instanceData { typedef struct configSettings_s { uchar *rulebase; /**< name of normalization rulebase to use */ - sbool bUseRawMsg; /**< use %rawmsg% instead of %msg% */ + int bUseRawMsg; /**< use %rawmsg% instead of %msg% */ } configSettings_t; static configSettings_t cs; |