Skip to content

Commit a36ef16

Browse files
committed
Address review comments
1 parent 67d5b3b commit a36ef16

File tree

1 file changed

+4
-4
lines changed
  • instrumentation/pulsar/pulsar-2.8/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8

1 file changed

+4
-4
lines changed

instrumentation/pulsar/pulsar-2.8/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/pulsar/v2_8/PulsarClientTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -684,10 +684,10 @@ void testSendMessageWithTxn() throws Exception {
684684
.sendTimeout(0, TimeUnit.SECONDS)
685685
.enableBatching(false)
686686
.create();
687-
Transaction txn =
688-
client.newTransaction().withTransactionTimeout(5, TimeUnit.SECONDS).build().get();
689-
testing.runWithSpan("parent1", () -> producer.newMessage(txn).value("test1").send());
690-
txn.commit();
687+
Transaction transaction =
688+
client.newTransaction().withTransactionTimeout(15, TimeUnit.SECONDS).build().get();
689+
testing.runWithSpan("parent1", () -> producer.newMessage(transaction).value("test1").send());
690+
transaction.commit();
691691

692692
testing.waitAndAssertTraces(
693693
trace ->

0 commit comments

Comments
 (0)