id: 1
unit: void ConsumerConfig::InitConfig()
file: src/ConsumerConfig.cc
start line: 92
end line: 327
size: 214 LOC
McCabe index: 82
number of parameters: 3

id: 2
unit: std::shared_ptr Message::BuildMessage()
file: src/Message.cc
start line: 150
end line: 226
size: 65 LOC
McCabe index: 26
number of parameters: 1

id: 3
unit: Napi::Value Consumer::NewInstance()
file: src/Consumer.cc
start line: 179
end line: 216
size: 33 LOC
McCabe index: 5
number of parameters: 2

id: 4
unit: Napi::Value Producer::NewInstance()
file: src/Producer.cc
start line: 56
end line: 94
size: 32 LOC
McCabe index: 3
number of parameters: 2

id: 5
unit: Napi::Value Consumer::BatchReceive()
file: src/Consumer.cc
start line: 262
end line: 293
size: 31 LOC
McCabe index: 3
number of parameters: 1

id: 6
unit: Napi::Value Consumer::Receive()
file: src/Consumer.cc
start line: 295
end line: 325
size: 30 LOC
McCabe index: 3
number of parameters: 1

id: 7
unit: Napi::Value Client::GetPartitionsForTopic()
file: src/Client.cc
start line: 228
end line: 261
size: 28 LOC
McCabe index: 4
number of parameters: 1

id: 8
unit: void MessageListenerProxy()
file: src/Consumer.cc
start line: 76
end line: 104
size: 24 LOC
McCabe index: 3
number of parameters: 3

id: 9
unit: void Client::SetLogHandler()
file: src/Client.cc
start line: 48
end line: 72
size: 24 LOC
McCabe index: 5
number of parameters: 1

id: 10
unit: void TokenSupplierProxy()
file: src/Authentication.cc
start line: 38
end line: 60
size: 23 LOC
McCabe index: 5
number of parameters: 3

id: 11
unit: void Consumer::Init()
file: src/Consumer.cc
start line: 34
end line: 57
size: 22 LOC
McCabe index: 1
number of parameters: 2

id: 12
unit: Napi::Value Consumer::AcknowledgeCumulativeId()
file: src/Consumer.cc
start line: 413
end line: 436
size: 21 LOC
McCabe index: 2
number of parameters: 1

id: 13
unit: Napi::Value Producer::Send()
file: src/Producer.cc
start line: 106
end line: 130
size: 21 LOC
McCabe index: 2
number of parameters: 1

id: 14
unit: Napi::Value Consumer::Acknowledge()
file: src/Consumer.cc
start line: 327
end line: 349
size: 20 LOC
McCabe index: 2
number of parameters: 1

id: 15
unit: Napi::Value Consumer::AcknowledgeId()
file: src/Consumer.cc
start line: 351
end line: 373
size: 20 LOC
McCabe index: 2
number of parameters: 1

id: 16
unit: Napi::Value Consumer::AcknowledgeCumulative()
file: src/Consumer.cc
start line: 389
end line: 411
size: 20 LOC
McCabe index: 2
number of parameters: 1

id: 17
unit: Napi::Value Consumer::Seek()
file: src/Consumer.cc
start line: 438
end line: 460
size: 20 LOC
McCabe index: 2
number of parameters: 1

id: 18
unit: Napi::Value Reader::NewInstance()
file: src/Reader.cc
start line: 148
end line: 172
size: 20 LOC
McCabe index: 3
number of parameters: 2

id: 19
unit: Napi::Value Reader::Seek()
file: src/Reader.cc
start line: 243
end line: 265
size: 20 LOC
McCabe index: 2
number of parameters: 1

id: 20
unit: static void subscribeCallback()
file: src/Consumer.cc
start line: 153
end line: 176
size: 19 LOC
McCabe index: 2
number of parameters: 3

id: 21
unit: Napi::Value Consumer::SeekTimestamp()
file: src/Consumer.cc
start line: 462
end line: 483
size: 19 LOC
McCabe index: 2
number of parameters: 1

id: 22
unit: Napi::Value Consumer::Close()
file: src/Consumer.cc
start line: 499
end line: 520
size: 19 LOC
McCabe index: 2
number of parameters: 1

id: 23
unit: Napi::Value Consumer::Unsubscribe()
file: src/Consumer.cc
start line: 522
end line: 543
size: 19 LOC
McCabe index: 2
number of parameters: 1

id: 24
unit: void ReaderListenerProxy()
file: src/Reader.cc
start line: 60
end line: 79
size: 19 LOC
McCabe index: 4
number of parameters: 3

id: 25
unit: Napi::Value Reader::SeekTimestamp()
file: src/Reader.cc
start line: 267
end line: 288
size: 19 LOC
McCabe index: 2
number of parameters: 1

id: 26
unit: Napi::Value Reader::Close()
file: src/Reader.cc
start line: 290
end line: 311
size: 19 LOC
McCabe index: 2
number of parameters: 1

id: 27
unit: Napi::Value Producer::Flush()
file: src/Producer.cc
start line: 132
end line: 152
size: 18 LOC
McCabe index: 2
number of parameters: 1

id: 28
unit: Napi::Value Producer::Close()
file: src/Producer.cc
start line: 154
end line: 174
size: 18 LOC
McCabe index: 2
number of parameters: 1

id: 29
unit: Napi::Value Client::Close()
file: src/Client.cc
start line: 291
end line: 311
size: 18 LOC
McCabe index: 2
number of parameters: 1

id: 30
unit: static void createReaderCallback()
file: src/Reader.cc
start line: 125
end line: 145
size: 18 LOC
McCabe index: 2
number of parameters: 3

id: 31
unit: static genCertFile()
file: src/Client.js
start line: 59
end line: 76
size: 17 LOC
McCabe index: 3
number of parameters: 0

id: 32
unit: Napi::Object Message::Init()
file: src/Message.cc
start line: 37
end line: 55
size: 16 LOC
McCabe index: 1
number of parameters: 2

id: 33
unit: Napi::Value MessageId::Deserialize()
file: src/MessageId.cc
start line: 102
end line: 120
size: 15 LOC
McCabe index: 2
number of parameters: 1

id: 34
unit: void MessageListener()
file: src/Consumer.cc
start line: 106
end line: 124
size: 15 LOC
McCabe index: 2
number of parameters: 3

id: 35
unit: void ReaderListener()
file: src/Reader.cc
start line: 81
end line: 97
size: 15 LOC
McCabe index: 2
number of parameters: 3

id: 36
unit: void Execute()
file: src/Consumer.cc
start line: 234
end line: 248
size: 14 LOC
McCabe index: 3
number of parameters: 0

id: 37
unit: Napi::Object Client::Init()
file: src/Client.cc
start line: 76
end line: 92
size: 14 LOC
McCabe index: 1
number of parameters: 2

id: 38
unit: void Reader::Init()
file: src/Reader.cc
start line: 33
end line: 48
size: 14 LOC
McCabe index: 1
number of parameters: 2

id: 39
unit: Napi::Value Reader::HasNext()
file: src/Reader.cc
start line: 223
end line: 236
size: 14 LOC
McCabe index: 3
number of parameters: 1

id: 40
unit: Napi::Value Message::GetProperties()
file: src/Message.cc
start line: 84
end line: 97
size: 14 LOC
McCabe index: 3
number of parameters: 1

id: 41
unit: Napi::Object MessageId::Init()
file: src/MessageId.cc
start line: 28
end line: 43
size: 13 LOC
McCabe index: 1
number of parameters: 2

id: 42
unit: void Client::LogMessage()
file: src/Client.cc
start line: 273
end line: 289
size: 13 LOC
McCabe index: 3
number of parameters: 5

id: 43
unit: void Execute()
file: src/Reader.cc
start line: 184
end line: 196
size: 13 LOC
McCabe index: 3
number of parameters: 0

id: 44
unit: void Producer::Init()
file: src/Producer.cc
start line: 29
end line: 42
size: 12 LOC
McCabe index: 1
number of parameters: 2

id: 45
unit: Napi::Value Reader::ReadNext()
file: src/Reader.cc
start line: 210
end line: 221
size: 12 LOC
McCabe index: 2
number of parameters: 1

id: 46
unit: void Consumer::SetListenerCallback()
file: src/Consumer.cc
start line: 127
end line: 140
size: 10 LOC
McCabe index: 3
number of parameters: 1

id: 47
unit: void Reader::SetListenerCallback()
file: src/Reader.cc
start line: 100
end line: 112
size: 10 LOC
McCabe index: 3
number of parameters: 1

id: 48
unit: Napi::Object MessageId::NewInstanceFromMessage()
file: src/MessageId.cc
start line: 50
end line: 58
size: 9 LOC
McCabe index: 1
number of parameters: 2

id: 49
unit: Napi::Object InitAll()
file: src/addon.cc
start line: 29
end line: 37
size: 9 LOC
McCabe index: 1
number of parameters: 2

id: 50
unit: Napi::Value Message::GetData()
file: src/Message.cc
start line: 99
end line: 107
size: 9 LOC
McCabe index: 2
number of parameters: 1

id: 51
unit: Napi::Value MessageId::Earliest()
file: src/MessageId.cc
start line: 74
end line: 81
size: 8 LOC
McCabe index: 1
number of parameters: 1

id: 52
unit: void Consumer::Cleanup()
file: src/Consumer.cc
start line: 490
end line: 497
size: 8 LOC
McCabe index: 2
number of parameters: 0

id: 53
unit: Napi::Object Authentication::Init()
file: src/Authentication.cc
start line: 87
end line: 97
size: 8 LOC
McCabe index: 1
number of parameters: 2

id: 54
unit: void LogMessageProxy()
file: src/Client.cc
start line: 263
end line: 271
size: 8 LOC
McCabe index: 1
number of parameters: 3

id: 55
unit: bool Message::ValidateCMessage()
file: src/Message.cc
start line: 141
end line: 148
size: 8 LOC
McCabe index: 2
number of parameters: 1

id: 56
unit: Napi::Value MessageId::Latest()
file: src/MessageId.cc
start line: 83
end line: 89
size: 7 LOC
McCabe index: 1
number of parameters: 1

id: 57
unit: static void FreeStringArray()
file: src/Message.h
start line: 56
end line: 62
size: 7 LOC
McCabe index: 2
number of parameters: 2

id: 58
unit: void Reader::Cleanup()
file: src/Reader.cc
start line: 313
end line: 319
size: 7 LOC
McCabe index: 2
number of parameters: 0

id: 59
unit: Napi::Value Message::GetTopicName()
file: src/Message.cc
start line: 68
end line: 74
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 60
unit: Napi::Value Message::GetRedeliveryCount()
file: src/Message.cc
start line: 76
end line: 82
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 61
unit: Napi::Value Message::GetMessageId()
file: src/Message.cc
start line: 109
end line: 115
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 62
unit: Napi::Value Message::GetEventTimestamp()
file: src/Message.cc
start line: 117
end line: 123
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 63
unit: Napi::Value Message::GetPublishTimestamp()
file: src/Message.cc
start line: 125
end line: 131
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 64
unit: Napi::Value Message::GetPartitionKey()
file: src/Message.cc
start line: 133
end line: 139
size: 7 LOC
McCabe index: 2
number of parameters: 1

id: 65
unit: Napi::Object MessageId::NewInstance()
file: src/MessageId.cc
start line: 65
end line: 70
size: 6 LOC
McCabe index: 1
number of parameters: 1

id: 66
unit: Napi::Value MessageId::Serialize()
file: src/MessageId.cc
start line: 93
end line: 100
size: 6 LOC
McCabe index: 1
number of parameters: 1

id: 67
unit: Napi::Value MessageId::ToString()
file: src/MessageId.cc
start line: 124
end line: 129
size: 6 LOC
McCabe index: 1
number of parameters: 1

id: 68
unit: inline void logMessageListenerError()
file: src/Consumer.cc
start line: 69
end line: 74
size: 6 LOC
McCabe index: 1
number of parameters: 2

id: 69
unit: void Consumer::NegativeAcknowledge()
file: src/Consumer.cc
start line: 375
end line: 380
size: 6 LOC
McCabe index: 1
number of parameters: 1

id: 70
unit: void Consumer::NegativeAcknowledgeId()
file: src/Consumer.cc
start line: 382
end line: 387
size: 6 LOC
McCabe index: 1
number of parameters: 1

id: 71
unit: void ThreadSafeDeferred::Resolve()
file: src/ThreadSafeDeferred.cc
start line: 86
end line: 91
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 72
unit: void ThreadSafeDeferred::Reject()
file: src/ThreadSafeDeferred.cc
start line: 93
end line: 98
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 73
unit: constructor()
file: src/Client.js
start line: 27
end line: 33
size: 6 LOC
McCabe index: 2
number of parameters: 1

id: 74
unit: Napi::Object Message::NewInstance()
file: src/Message.cc
start line: 57
end line: 62
size: 6 LOC
McCabe index: 1
number of parameters: 2

id: 75
unit: static void SetString()
file: src/Message.h
start line: 51
end line: 55
size: 5 LOC
McCabe index: 1
number of parameters: 3

id: 76
unit: std::shared_ptr ThreadSafeDeferred::New()
file: src/ThreadSafeDeferred.cc
start line: 49
end line: 53
size: 5 LOC
McCabe index: 1
number of parameters: 1

id: 77
unit: void ThreadSafeDeferred::Resolve()
file: src/ThreadSafeDeferred.cc
start line: 80
end line: 84
size: 5 LOC
McCabe index: 2
number of parameters: 0

id: 78
unit: Napi::Object MessageId::NewInstance()
file: src/MessageId.cc
start line: 60
end line: 63
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 79
unit: void OnOK()
file: src/Consumer.cc
start line: 249
end line: 252
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 80
unit: Napi::Value Consumer::IsConnected()
file: src/Consumer.cc
start line: 485
end line: 488
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 81
unit: constructor()
file: src/AuthenticationOauth2.js
start line: 22
end line: 25
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 82
unit: Napi::Value Producer::GetProducerName()
file: src/Producer.cc
start line: 176
end line: 179
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 83
unit: Napi::Value Producer::GetTopic()
file: src/Producer.cc
start line: 181
end line: 184
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 84
unit: Napi::Value Producer::IsConnected()
file: src/Producer.cc
start line: 186
end line: 189
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 85
unit: constructor()
file: src/AuthenticationAthenz.js
start line: 23
end line: 26
size: 4 LOC
McCabe index: 2
number of parameters: 1

id: 86
unit: void SchemaInfo::SetProducerSchema()
file: src/SchemaInfo.cc
start line: 68
end line: 71
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 87
unit: void SchemaInfo::SetConsumerSchema()
file: src/SchemaInfo.cc
start line: 73
end line: 76
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 88
unit: void OnOK()
file: src/Reader.cc
start line: 197
end line: 200
size: 4 LOC
McCabe index: 1
number of parameters: 0

id: 89
unit: Napi::Value Reader::IsConnected()
file: src/Reader.cc
start line: 238
end line: 241
size: 4 LOC
McCabe index: 1
number of parameters: 1

id: 90
unit: token: async()
file: tstest.ts
start line: 70
end line: 72
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 91
unit: std::string Consumer::GetSubscriptionName()
file: src/Consumer.cc
start line: 220
end line: 222
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 92
unit: std::shared_ptr ProducerConfig::GetCProducerConfig()
file: src/ProducerConfig.cc
start line: 215
end line: 217
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 93
unit: Napi::Value Client::CreateProducer()
file: src/Client.cc
start line: 217
end line: 219
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 94
unit: Napi::Value Client::Subscribe()
file: src/Client.cc
start line: 220
end line: 222
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 95
unit: Napi::Value Client::CreateReader()
file: src/Client.cc
start line: 224
end line: 226
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 96
unit: bool ThreadSafeDeferred::IsDone()
file: src/ThreadSafeDeferred.cc
start line: 100
end line: 102
size: 3 LOC
McCabe index: 2
number of parameters: 0

id: 97
unit: std::shared_ptr ReaderConfig::GetCReaderConfig()
file: src/ReaderConfig.cc
start line: 117
end line: 119
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 98
unit: createProducer()
file: src/Client.js
start line: 35
end line: 37
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 99
unit: subscribe()
file: src/Client.js
start line: 39
end line: 41
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 100
unit: createReader()
file: src/Client.js
start line: 43
end line: 45
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 101
unit: getPartitionsForTopic()
file: src/Client.js
start line: 47
end line: 49
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 102
unit: close()
file: src/Client.js
start line: 51
end line: 53
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 103
unit: static setLogHandler()
file: src/Client.js
start line: 55
end line: 57
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 104
unit: std::shared_ptr ConsumerConfig::GetCConsumerConfig()
file: src/ConsumerConfig.cc
start line: 335
end line: 337
size: 3 LOC
McCabe index: 1
number of parameters: 0

id: 105
unit: constructor()
file: src/AuthenticationBasic.js
start line: 22
end line: 24
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 106
unit: constructor()
file: src/AuthenticationToken.js
start line: 23
end line: 25
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 107
unit: constructor()
file: src/AuthenticationTls.js
start line: 23
end line: 25
size: 3 LOC
McCabe index: 1
number of parameters: 1

id: 108
unit: std::unique_ptr dataPtr()
file: src/Authentication.cc
start line: 72
end line: 73
size: 2 LOC
McCabe index: 1
number of parameters: 1

id: 109
unit: void nofree()
file: src/MessageId.cc
start line: 72
end line: 72
size: 1 LOC
McCabe index: 1
number of parameters: 1

id: 110
unit: void serializeFinalizeCallback()
file: src/MessageId.cc
start line: 91
end line: 91
size: 1 LOC
McCabe index: 1
number of parameters: 2

id: 111
unit: std::shared_ptr MessageId::GetCMessageId()
file: src/MessageId.cc
start line: 122
end line: 122
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 112
unit: void Consumer::SetCConsumer()
file: src/Consumer.cc
start line: 126
end line: 126
size: 1 LOC
McCabe index: 1
number of parameters: 1

id: 113
unit: std::string Consumer::GetTopic()
file: src/Consumer.cc
start line: 218
end line: 218
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 114
unit: void OnError()
file: src/Consumer.cc
start line: 253
end line: 253
size: 1 LOC
McCabe index: 1
number of parameters: 1

id: 115
unit: void FinalizeTokenSupplierCallback()
file: src/Authentication.cc
start line: 29
end line: 29
size: 1 LOC
McCabe index: 1
number of parameters: 3

id: 116
unit: std::string ProducerConfig::GetTopic()
file: src/ProducerConfig.cc
start line: 219
end line: 219
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 117
unit: void Producer::SetCProducer()
file: src/Producer.cc
start line: 44
end line: 44
size: 1 LOC
McCabe index: 1
number of parameters: 1

id: 118
unit: void FinalizeListenerCallback()
file: src/ReaderConfig.cc
start line: 41
end line: 41
size: 1 LOC
McCabe index: 1
number of parameters: 3

id: 119
unit: std::string ReaderConfig::GetTopic()
file: src/ReaderConfig.cc
start line: 121
end line: 121
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 120
unit: std::shared_ptr ReaderConfig::GetCStartMessageId()
file: src/ReaderConfig.cc
start line: 123
end line: 123
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 121
unit: void Reader::SetCReader()
file: src/Reader.cc
start line: 99
end line: 99
size: 1 LOC
McCabe index: 1
number of parameters: 1

id: 122
unit: void OnError()
file: src/Reader.cc
start line: 201
end line: 201
size: 1 LOC
McCabe index: 1
number of parameters: 1

id: 123
unit: std::shared_ptr Message::GetCMessage()
file: src/Message.cc
start line: 66
end line: 66
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 124
unit: void FinalizeListenerCallback()
file: src/ConsumerConfig.cc
start line: 79
end line: 79
size: 1 LOC
McCabe index: 1
number of parameters: 3

id: 125
unit: std::string ConsumerConfig::GetTopic()
file: src/ConsumerConfig.cc
start line: 339
end line: 339
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 126
unit: std::vector ConsumerConfig::GetTopics()
file: src/ConsumerConfig.cc
start line: 340
end line: 340
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 127
unit: std::string ConsumerConfig::GetTopicsPattern()
file: src/ConsumerConfig.cc
start line: 341
end line: 341
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 128
unit: std::string ConsumerConfig::GetSubscription()
file: src/ConsumerConfig.cc
start line: 342
end line: 342
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 129
unit: int64_t ConsumerConfig::GetAckTimeoutMs()
file: src/ConsumerConfig.cc
start line: 349
end line: 349
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 130
unit: int64_t ConsumerConfig::GetNAckRedeliverTimeoutMs()
file: src/ConsumerConfig.cc
start line: 350
end line: 350
size: 1 LOC
McCabe index: 1
number of parameters: 0

id: 131
unit: inline void Reject()
file: src/ThreadSafeDeferred.h
start line: 73
end line: 73
size: 1 LOC
McCabe index: 1
number of parameters: 0