X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=service%2Fnotification%2Fsrc%2Fconsumer%2FNSConsumerScheduler.c;h=2e13b5940f482a348c48ce5c91c03c864cfaaa72;hb=7f00f942c39b7bc27c7eeecf213a239c3fe4173c;hp=d7552e41d641ee2bd94bb8b1992c353637549ad4;hpb=edcfc3d2329da7b914771c0dcff5f42c9b74fd93;p=platform%2Fupstream%2Fiotivity.git diff --git a/service/notification/src/consumer/NSConsumerScheduler.c b/service/notification/src/consumer/NSConsumerScheduler.c index d7552e4..2e13b59 100644 --- a/service/notification/src/consumer/NSConsumerScheduler.c +++ b/service/notification/src/consumer/NSConsumerScheduler.c @@ -41,6 +41,10 @@ #include "NSConsumerNetworkEventListener.h" #include "NSConsumerSystem.h" +#ifdef WITH_MQ +#include "NSConsumerMQPlugin.h" +#endif + void * NSConsumerMsgHandleThreadFunc(void * handle); void * NSConsumerMsgPushThreadFunc(void * data); @@ -78,7 +82,7 @@ NSResult NSConsumerMessageHandlerInit() NS_VERIFY_NOT_NULL(consumerUuid, NS_ERROR); NSSetConsumerId(consumerUuid); - NS_LOG_V(DEBUG, "Consumer ID : %s", *NSGetConsumerId()); + NS_LOG_V(INFO_PRIVATE, "Consumer ID : %s", *NSGetConsumerId()); NS_LOG(DEBUG, "listener init"); NSResult ret = NSConsumerListenerInit(); @@ -328,6 +332,13 @@ void NSConsumerTaskProcessing(NSTask * task) NSConsumerInternalTaskProcessing(task); break; } +#ifdef WITH_MQ + case TASK_MQ_REQ_SUBSCRIBE: + { + NSConsumerMQTaskProcessing(task); + break; + } +#endif default: { NS_LOG(ERROR, "Unknown type of task");