Skip to content

Commit 88fb032

Browse files
committed
Switch tryAddMessage to use traceSync
1 parent 4ea2800 commit 88fb032

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

packages/datadog-instrumentations/src/azure-service-bus.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ addHook({ name: '@azure/service-bus', versions: ['>=7.9.2'] }, (obj) => {
3838
shimmer.wrap(batch, 'tryAddMessage', tryAddMessage => function (msg) {
3939
const functionName = tryAddMessage.name
4040
const config = this._context.config
41-
return producerCh.tracePromise(
41+
return producerCh.traceSync(
4242
tryAddMessage, { config, functionName, batch, msg }, this, ...arguments)
4343
})
4444
return batch

packages/datadog-plugin-azure-service-bus/test/integration-test/server.mjs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,14 +54,14 @@ await sender1.scheduleMessages(amqpMessages, scheduledEnqueueTimeUtc)
5454

5555
// queue batching
5656
const batch1 = await sender1.createMessageBatch()
57-
await batch1.tryAddMessage(messages[0])
58-
await batch1.tryAddMessage(messages[1])
57+
batch1.tryAddMessage(messages[0])
58+
batch1.tryAddMessage(messages[1])
5959
await sender1.sendMessages(batch1)
6060

6161
// topic batching
6262
const batch2 = await sender2.createMessageBatch()
63-
await batch2.tryAddMessage(messages[0])
64-
await batch2.tryAddMessage(messages[1])
63+
batch2.tryAddMessage(messages[0])
64+
batch2.tryAddMessage(messages[1])
6565
await sender2.sendMessages(batch2)
6666

6767
await sender1.close()

0 commit comments

Comments
 (0)