Skip to content

Commit

Permalink
Disable span.debug until we can correctly change the log level for th…
Browse files Browse the repository at this point in the history
…e span logger.
  • Loading branch information
mdebarros committed Sep 19, 2019
1 parent 3713d06 commit 971c1f2
Showing 1 changed file with 18 additions and 15 deletions.
33 changes: 18 additions & 15 deletions src/domain/transfer/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -61,11 +61,12 @@ const prepare = async (headers, dataUri, payload, span) => {
Logger.debug(`domain::transfer::prepare::messageProtocol - ${messageProtocol}`)
Logger.debug(`domain::transfer::prepare::topicConfig - ${topicConfig}`)
Logger.debug(`domain::transfer::prepare::kafkaConfig - ${kafkaConfig}`)
await span.debug({
messageProtocol,
topicName: topicConfig.topicName,
clientId: kafkaConfig.rdkafkaConf['client.id']
})
// TODO: re-enable once we are able to configure the log-level
// await span.debug({
// messageProtocol,
// topicName: topicConfig.topicName,
// clientId: kafkaConfig.rdkafkaConf['client.id']
// })
messageProtocol = await span.injectContextToMessage(messageProtocol)
await KafkaUtil.Producer.produceMessage(messageProtocol, topicConfig, kafkaConfig)
return true
Expand Down Expand Up @@ -142,11 +143,12 @@ const getTransferById = async (headers, params, span) => {
Logger.info(`domain::transfer::get::messageProtocol - ${messageProtocol}`)
Logger.info(`domain::transfer::get::topicConfig - ${topicConfig}`)
Logger.info(`domain::transfer::get::kafkaConfig - ${kafkaConfig}`)
await span.debug({
messageProtocol,
topicName: topicConfig.topicName,
clientId: kafkaConfig.rdkafkaConf['client.id']
})
// TODO: re-enable once we are able to configure the log-level
// await span.debug({
// messageProtocol,
// topicName: topicConfig.topicName,
// clientId: kafkaConfig.rdkafkaConf['client.id']
// })
messageProtocol = await span.injectContextToMessage(messageProtocol)
await KafkaUtil.Producer.produceMessage(messageProtocol, topicConfig, kafkaConfig)
return true
Expand Down Expand Up @@ -183,11 +185,12 @@ const transferError = async (headers, dataUri, payload, params, span) => {
Logger.debug(`domain::transfer::abort::messageProtocol - ${messageProtocol}`)
Logger.debug(`domain::transfer::abort::topicConfig - ${topicConfig}`)
Logger.debug(`domain::transfer::abort::kafkaConfig - ${kafkaConfig}`)
await span.debug({
messageProtocol,
topicName: topicConfig.topicName,
clientId: kafkaConfig.rdkafkaConf['client.id']
})
// TODO: re-enable once we are able to configure the log-level
// await span.debug({
// messageProtocol,
// topicName: topicConfig.topicName,
// clientId: kafkaConfig.rdkafkaConf['client.id']
// })
messageProtocol = await span.injectContextToMessage(messageProtocol)
await KafkaUtil.Producer.produceMessage(messageProtocol, topicConfig, kafkaConfig)
return true
Expand Down

0 comments on commit 971c1f2

Please sign in to comment.