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();
break;
}
- NSConsumerQueue * queue = *(NSGetMsgHandleQueue());;
+ NSConsumerQueue * queue = *(NSGetMsgHandleQueue());
if (!queue)
{
usleep(2000);
NSThreadLock(queueHandleThread);
NS_LOG(DEBUG, "msg handler working");
+ queue = *(NSGetMsgHandleQueue());
obj = NSPopQueue(queue);
if (obj)
void NSConsumerTaskProcessing(NSTask * task)
{
+ NS_VERIFY_NOT_NULL_V(task);
switch (task->taskType)
{
case TASK_EVENT_CONNECTED: