diff options
| -rw-r--r-- | src/plugin_manager/plugin_manager.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/plugin_manager/plugin_manager.c b/src/plugin_manager/plugin_manager.c index 1480c25..9f9f7bd 100644 --- a/src/plugin_manager/plugin_manager.c +++ b/src/plugin_manager/plugin_manager.c @@ -773,6 +773,8 @@ int stellar_session_mq_subscribe(struct stellar *st, int topic_id, on_session_ms struct stellar_mq_subscriber_info *p=NULL; while( (p=(struct stellar_mq_subscriber_info *)utarray_next(session_plugin_schema->registed_session_mq_subscriber_info,p))) { + if(p->topic_id==topic_id) + { struct stellar_mq_subscriber *tmp_subscriber=topic->subscribers; int cnt=0; while(tmp_subscriber) @@ -785,6 +787,7 @@ int stellar_session_mq_subscribe(struct stellar *st, int topic_id, on_session_ms cnt++; tmp_subscriber=tmp_subscriber->next; } + } }; struct stellar_mq_subscriber *new_subscriber = CALLOC(struct stellar_mq_subscriber,1); |