projects
/
platform
/
upstream
/
iotivity.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
replace : iotivity -> iotivity-sec
[platform/upstream/iotivity.git]
/
service
/
notification
/
src
/
consumer
/
NSConsumerScheduler.c
diff --git
a/service/notification/src/consumer/NSConsumerScheduler.c
b/service/notification/src/consumer/NSConsumerScheduler.c
index
d7552e4
..
2e13b59
100644
(file)
--- a/
service/notification/src/consumer/NSConsumerScheduler.c
+++ b/
service/notification/src/consumer/NSConsumerScheduler.c
@@
-41,6
+41,10
@@
#include "NSConsumerNetworkEventListener.h"
#include "NSConsumerSystem.h"
#include "NSConsumerNetworkEventListener.h"
#include "NSConsumerSystem.h"
+#ifdef WITH_MQ
+#include "NSConsumerMQPlugin.h"
+#endif
+
void * NSConsumerMsgHandleThreadFunc(void * handle);
void * NSConsumerMsgPushThreadFunc(void * data);
void * NSConsumerMsgHandleThreadFunc(void * handle);
void * NSConsumerMsgPushThreadFunc(void * data);
@@
-78,7
+82,7
@@
NSResult NSConsumerMessageHandlerInit()
NS_VERIFY_NOT_NULL(consumerUuid, NS_ERROR);
NSSetConsumerId(consumerUuid);
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();
NS_LOG(DEBUG, "listener init");
NSResult ret = NSConsumerListenerInit();
@@
-328,6
+332,13
@@
void NSConsumerTaskProcessing(NSTask * task)
NSConsumerInternalTaskProcessing(task);
break;
}
NSConsumerInternalTaskProcessing(task);
break;
}
+#ifdef WITH_MQ
+ case TASK_MQ_REQ_SUBSCRIBE:
+ {
+ NSConsumerMQTaskProcessing(task);
+ break;
+ }
+#endif
default:
{
NS_LOG(ERROR, "Unknown type of task");
default:
{
NS_LOG(ERROR, "Unknown type of task");