in src/push_consumer.cpp [79:133]
void RocketMQPushConsumer::SetOptions(Local<Object> options)
{
// set name server
Local<Value> _name_server_v = Nan::Get(options, Nan::New<String>("nameServer").ToLocalChecked()).ToLocalChecked();
if(_name_server_v->IsString())
{
Nan::Utf8String namesrv(_name_server_v);
SetPushConsumerNameServerAddress(consumer_ptr, *namesrv);
}
// set thread count
Local<Value> _thread_count_v = Nan::Get(options, Nan::New<String>("threadCount").ToLocalChecked()).ToLocalChecked();
if(_thread_count_v->IsNumber())
{
int thread_count = Nan::To<int32_t>(_thread_count_v).FromJust();
if(thread_count > 0)
{
SetPushConsumerThreadCount(consumer_ptr, thread_count);
}
}
// set message batch max size
Local<Value> _max_batch_size_v = Nan::Get(options, Nan::New<String>("maxBatchSize").ToLocalChecked()).ToLocalChecked();
if(_max_batch_size_v->IsNumber())
{
int max_batch_size = Nan::To<int32_t>(_max_batch_size_v).FromJust();
if(max_batch_size > 0)
{
SetPushConsumerMessageBatchMaxSize(consumer_ptr, max_batch_size);
}
}
// set log num & single log size
int file_num = 3;
int64 file_size = 104857600;
Local<Value> _log_file_num_v = Nan::Get(options, Nan::New<String>("logFileNum").ToLocalChecked()).ToLocalChecked();
Local<Value> _log_file_size_v = Nan::Get(options, Nan::New<String>("logFileSize").ToLocalChecked()).ToLocalChecked();
if(_log_file_num_v->IsNumber())
{
file_num = _log_file_num_v->Int32Value();
}
if(_log_file_size_v->IsNumber())
{
file_size = _log_file_size_v->Int32Value();
}
SetPushConsumerLogFileNumAndSize(consumer_ptr, file_num, file_size);
// set log level
Local<Value> _log_level_v = Nan::Get(options, Nan::New<String>("logLevel").ToLocalChecked()).ToLocalChecked();
if(_log_level_v->IsNumber())
{
int level = _log_level_v->Int32Value();
SetPushConsumerLogLevel(consumer_ptr, (CLogLevel) level);
}
}