NS_LOG(DEBUG, "NSProviderGetConsumerTopics - IN");
pthread_mutex_lock(&nsInitMutex);
- if(!consumerId)
+ if(!consumerId || consumerId[0] == '\0')
{
NS_LOG(DEBUG, "consumer id should be set");
pthread_mutex_unlock(&nsInitMutex);
NS_LOG(DEBUG, "NSProviderAddTopics - IN");
pthread_mutex_lock(&nsInitMutex);
- if(!topicName)
+ if(!topicName || topicName == '\0')
{
pthread_mutex_unlock(&nsInitMutex);
NS_LOG(DEBUG, "topic Name should be set");
NS_LOG(DEBUG, "NSProviderDeleteTopics - IN");
pthread_mutex_lock(&nsInitMutex);
- if(!topicName)
+ if(!topicName || topicName[0] == '\0')
{
pthread_mutex_unlock(&nsInitMutex);
NS_LOG(DEBUG, "topic Name should be set");
NS_LOG(DEBUG, "NSProviderSelectTopics - IN");
pthread_mutex_lock(&nsInitMutex);
- if(!consumerId || !topicName || !NSGetPolicy())
+ if(!consumerId || consumerId[0] == '\0' || !topicName || topicName[0] == '\0' || !NSGetPolicy())
{
NS_LOG(DEBUG, "consumer id should be set for topic subscription or "
"Configuration must set to true.");
NS_LOG(DEBUG, "NSProviderUnselectTopics - IN");
pthread_mutex_lock(&nsInitMutex);
- if(!consumerId || !topicName || !NSGetPolicy())
+ if(!consumerId || consumerId[0] == '\0' || !topicName || topicName[0] == '\0' || !NSGetPolicy())
{
NS_LOG(DEBUG, "consumer id should be set for topic subscription or "
"Configuration must set to true.");
NSCacheElement * newObj = (NSCacheElement *) OICMalloc(sizeof(NSCacheElement));\r
newObj->data = (NSCacheData *) topicSubData;\r
newObj->next = NULL;\r
+\r
NSStorageWrite(consumerTopicList, newObj);\r
}\r
}\r
newObj->data = node->taskData;\r
newObj->next = NULL;\r
NSStorageWrite(consumerTopicList, newObj);\r
+ NSCacheTopicSubData * topicSubData = (NSCacheTopicSubData *) node->taskData;\r
+ NSSendTopicUpdationToConsumer(topicSubData->id);\r
break;\r
case TASK_UNSUBSCRIBE_TOPIC:\r
NS_LOG(DEBUG, "CASE TASK_SUBSCRIBE_TOPIC : ");\r