+ if(subData->messageObId != 0)
+ {
+ if (msg->topic && (msg->topic)[0] != '\0')
+ {
+ NS_LOG_V(DEBUG, "this is topic message: %s", msg->topic);
+
+ if (NSProviderIsTopicSubScribed(consumerTopicList->head, subData->id, msg->topic))
+ {
+ obArray[obCount++] = subData->messageObId;
+ }
+ }
+ else
+ {
+ obArray[obCount++] = subData->messageObId;
+ }
+ }
+
+#if (defined WITH_CLOUD)
+ if (subData->remote_messageObId != 0)
+ {
+ if (msg->topic && (msg->topic)[0] != '\0')
+ {
+ NS_LOG_V(DEBUG, "this is topic message via remote server: %s", msg->topic);
+ if (NSProviderIsTopicSubScribed(consumerTopicList->head, subData->id, msg->topic))
+ {
+ obArray[obCount++] = subData->remote_messageObId;
+ }
+ }
+ else
+ {
+ obArray[obCount++] = subData->remote_messageObId;
+ }
+ }
+#endif
+