Skip to content

Commit

Permalink
Merge pull request #22 from geraldguillaume/1.0-FTY-master
Browse files Browse the repository at this point in the history
 [issues/217] mlm_client_set_consumer broke the stream when pattern is *
  • Loading branch information
boricj authored Mar 8, 2019
2 parents f32bd2d + 70c81d1 commit 90b2995
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion src/mlm_client_engine.inc
Original file line number Diff line number Diff line change
Expand Up @@ -1723,7 +1723,11 @@ int
mlm_client_set_consumer (mlm_client_t *self, const char *stream, const char *pattern)
{
assert (self);

// https://github.com/zeromq/malamute/issues/217
// problem : if pattern "*" is used, the related stream will be broken and
// mlm broker will start overcosumming 100% CPU forever
if (streq(pattern,"*"))
return -1;
zsock_send (self->actor, "sss", "SET CONSUMER", stream, pattern);
if (s_accept_reply (self, "SUCCESS", "FAILURE", NULL))
return -1; // Interrupted or timed-out
Expand Down

0 comments on commit 90b2995

Please sign in to comment.