Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use withTransactions method of org.testcontainers.containers.PulsarContainer class

Best Testcontainers-java code snippet using org.testcontainers.containers.PulsarContainer.withTransactions

Source:PulsarContainerTest.java

...82    @Test83    public void testTransactions() throws Exception {84        try (85            // constructorWithTransactions {86            PulsarContainer pulsar = new PulsarContainer(PULSAR_IMAGE).withTransactions();87            // }88        ) {89            pulsar.start();90            try (PulsarAdmin pulsarAdmin = PulsarAdmin.builder().serviceHttpUrl(pulsar.getHttpServiceUrl()).build()) {91                assertThat(92                    pulsarAdmin93                        .topics()94                        .getList("pulsar/system")95                        .contains("persistent://pulsar/system/transaction_coordinator_assign-partition-0")96                )97                    .isTrue();98            }99            testTransactionFunctionality(pulsar.getPulsarBrokerUrl());100        }101    }102    @Test103    public void testTransactionsAndFunctionsWorker() throws Exception {104        try (PulsarContainer pulsar = new PulsarContainer(PULSAR_IMAGE).withTransactions().withFunctionsWorker()) {105            pulsar.start();106            try (PulsarAdmin pulsarAdmin = PulsarAdmin.builder().serviceHttpUrl(pulsar.getHttpServiceUrl()).build();) {107                assertThat(108                    pulsarAdmin109                        .topics()110                        .getList("pulsar/system")111                        .contains("persistent://pulsar/system/transaction_coordinator_assign-partition-0")112                )113                    .isTrue();114                assertThat(pulsarAdmin.functions().getFunctions("public", "default")).hasSize(0);115            }116            testTransactionFunctionality(pulsar.getPulsarBrokerUrl());117        }118    }...

Source:PulsarContainer.java

...53    public PulsarContainer withFunctionsWorker() {54        functionsWorkerEnabled = true;55        return this;56    }57    public PulsarContainer withTransactions() {58        transactionsEnabled = true;59        return this;60    }61    public String getPulsarBrokerUrl() {62        return String.format("pulsar://%s:%s", getHost(), getMappedPort(BROKER_PORT));63    }64    public String getHttpServiceUrl() {65        return String.format("http://%s:%s", getHost(), getMappedPort(BROKER_HTTP_PORT));66    }67    protected void setupCommandAndEnv() {68        String standaloneBaseCommand =69            "/pulsar/bin/apply-config-from-env.py /pulsar/conf/standalone.conf " + "&& bin/pulsar standalone";70        if (!functionsWorkerEnabled) {71            standaloneBaseCommand += " --no-functions-worker -nss";...

withTransactions

Using AI Code Generation

1package org.testcontainers.containers;2import org.apache.pulsar.client.admin.PulsarAdmin;3import org.apache.pulsar.client.admin.PulsarAdminException;4import org.apache.pulsar.client.api.Consumer;5import org.apache.pulsar.client.api.PulsarClient;6import org.apache.pulsar.client.api.PulsarClientException;7import org.apache.pulsar.client.api.Producer;8import org.apache.pulsar.client.api.Schema;9import org.apache.pulsar.client.api.SubscriptionType;10import org.apache.pulsar.client.api.transaction.Transaction;11import org.apache.pulsar.client.api.transaction.TxnID;12import org.apache.pulsar.client.impl.schema.JSONSchema;13import org.apache.pulsar.common.naming.TopicName;14import org.apache.pulsar.common.schema.SchemaType;15import org.junit.Test;16import java.util.Collections;17public class PulsarContainerTest {18    public void test() throws PulsarAdminException, PulsarClientException {19        try (PulsarContainer pulsarContainer = new PulsarContainer("2.5.2")) {20            pulsarContainer.start();21            PulsarAdmin admin = PulsarAdmin.builder()22                    .serviceHttpUrl(pulsarContainer.getHttpServiceUrl())23                    .build();24            PulsarClient client = PulsarClient.builder()25                    .serviceUrl(pulsarContainer.getPulsarBrokerUrl())26                    .build();27            pulsarContainer.withTransaction(admin, client, (transaction, pulsarClient) -> {28                admin.topics().createPartitionedTopic(topicName, 1);29                Producer<String> producer = pulsarClient.newProducer(Schema.STRING)30                        .topic(topicName)31                        .enableBatching(false)32                        .create();33                producer.newMessage()34                        .value("message-1")35                        .send();36                producer.newMessage()37                        .value("message-2")38                        .send();39                producer.newMessage()40                        .value("message-3")41                        .send();42                Transaction txn = transaction.newTransaction()43                        .withTransactionTimeout(30, 0)44                        .build()45                        .get();46                TxnID txnID = txn.getTxnID();47                producer.newMessage(txnID)48                        .value("message-4")49                        .send();50                producer.newMessage(txnID)51                        .value("message-

withTransactions

Using AI Code Generation

1package org.testcontainers.containers;2import org.apache.pulsar.client.api.ClientBuilder;3import org.apache.pulsar.client.api.Consumer;4import org.apache.pulsar.client.api.Message;5import org.apache.pulsar.client.api.MessageId;6import org.apache.pulsar.client.api.Producer;7import org.apache.pulsar.client.api.PulsarClientException;8import org.apache.pulsar.client.api.PulsarClient;9import org.apache.pulsar.client.api.SubscriptionType;10import java.util.concurrent.TimeUnit;11public class PulsarContainerTest {12    public static void main(String[] args) throws Exception {13        try (PulsarContainer pulsarContainer = new PulsarContainer()) {14            pulsarContainer.start();15            String serviceUrl = pulsarContainer.getPulsarBrokerUrl();16            System.out.println("Service URL: " + serviceUrl);17            PulsarClient client = PulsarClient.builder()18                    .serviceUrl(serviceUrl)19                    .build();20            String subscriptionName = "my-subscription";21            String message = "Hello World!";22            System.out.println("Creating topic " + topicName);23            client.admin().topics().createPartitionedTopic(topicName, 1);24            System.out.println("Creating subscription " + subscriptionName);25            client.newConsumer()26                    .topic(topicName)27                    .subscriptionName(subscriptionName)28                    .subscriptionType(SubscriptionType.Shared)29                    .subscribe();30            System.out.println("Creating producer");31            Producer<String> producer = client.newProducer()32                    .topic(topicName)33                    .create();34            System.out.println("Sending message " + message);35            producer.send(message);36            System.out.println("Closing producer");37            producer.close();38            System.out.println("Consuming message");39            Consumer<String> consumer = client.newConsumer()40                    .topic(topicName)41                    .subscriptionName(subscriptionName)42                    .subscriptionType(SubscriptionType.Shared)43                    .subscribe();44            Message<String> msg = consumer.receive(5, TimeUnit.SECONDS);45            System.out.println("Message received: " + msg.getValue());46            MessageId msgId = msg.getMessageId();47            System.out.println("Closing consumer");48            consumer.close();49            System.out.println("Acknowledging message");50            client.newConsumer()51                    .topic(topicName)52                    .subscriptionName(subscriptionName)53                    .subscriptionType(SubscriptionType.Shared)54                    .acknowledgeCumulative(msg

withTransactions

Using AI Code Generation

1import java.util.concurrent.ExecutionException;2import org.apache.pulsar.client.api.Consumer;3import org.apache.pulsar.client.api.Message;4import org.apache.pulsar.client.api.Producer;5import org.apache.pulsar.client.api.PulsarClient;6import org.apache.pulsar.client.api.PulsarClientException;7import org.apache.pulsar.client.api.Schema;8import org.apache.pulsar.client.api.SubscriptionType;9import org.apache.pulsar.client.impl.schema.JSONSchema;10import org.testcontainers.containers.PulsarContainer;11public class 1 {12    public static void main(String[] args) throws PulsarClientException, ExecutionException, InterruptedException {13        PulsarContainer pulsarContainer = new PulsarContainer("2.8.0")14                .withTransactionCoordinator()15                .withTransactionMetadataStore();16        pulsarContainer.start();17        PulsarClient client = PulsarClient.builder()18                .serviceUrl(pulsarContainer.getHttpServiceUrl())19                .build();20        String myTopic = "my-topic";21        Producer<String> producer = client.newProducer(Schema.STRING)22                .topic(myTopic)23                .create();24        Consumer<String> consumer = client.newConsumer(Schema.STRING)25                .topic(myTopic)26                .subscriptionName("my-subscription")27                .subscriptionType(SubscriptionType.Exclusive)28                .subscribe();29        pulsarContainer.withTransactions(transaction -> {30            producer.newMessage(transaction)31                    .value("Hello")32                    .send();33            Message<String> message = consumer.receive();34            System.out.println(message.getValue());35            consumer.acknowledge(message);36        });37        pulsarContainer.stop();38    }39}40import java.util.concurrent.ExecutionException;41import org.apache.pulsar.client.api.Consumer;42import org.apache.pulsar.client.api.Message;43import org.apache.pulsar.client.api.Producer;44import org.apache.pulsar.client.api.PulsarClient;45import org.apache.pulsar.client.api.PulsarClientException;46import org.apache.pulsar.client.api.Schema;47import org.apache.pulsar.client.api.SubscriptionType;48import org.apache.pulsar.client.impl.schema.JSONSchema;49import org.testcontainers.containers.PulsarContainer;50public class 2 {51    public static void main(String[] args) throws PulsarClientException, Execution

withTransactions

Using AI Code Generation

1import java.io.IOException;2import java.util.concurrent.ExecutionException;3import org.apache.pulsar.client.admin.PulsarAdmin;4import org.apache.pulsar.client.admin.PulsarAdminException;5import org.apache.pulsar.client.api.Consumer;6import org.apache.pulsar.client.api.Message;7import org.apache.pulsar.client.api.MessageId;8import org.apache.pulsar.client.api.Producer;9import org.apache.pulsar.client.api.PulsarClient;10import org.apache.pulsar.client.api.PulsarClientException;11import org.apache.pulsar.client.api.SubscriptionType;12public class 1 {13    public static void main(String[] args) throws PulsarClientException, IOException, PulsarAdminException, ExecutionException, InterruptedException {14        PulsarContainer pulsarContainer = new PulsarContainer();15        pulsarContainer.start();16        PulsarClient pulsarClient = PulsarClient.builder()17                .serviceUrl(pulsarContainer.getPulsarBrokerUrl())18                .build();19        Producer<byte[]> producer = pulsarClient.newProducer()20                .topic(topicName)21                .create();22        producer.send("Message 1".getBytes());23        producer.send("Message 2".getBytes());24        producer.send("Message 3".getBytes());25        producer.send("Message 4".getBytes());26        producer.send("Message 5".getBytes());27        Consumer<byte[]> consumer = pulsarClient.newConsumer()28                .topic(topicName)29                .subscriptionName("test")30                .subscriptionType(SubscriptionType.Shared)31                .subscribe();32        Message<byte[]> message = consumer.receive();33        System.out.println("Received message: " + new String(message.getData()));34        consumer.acknowledge(message);35        MessageId messageId = message.getMessageId();36        System.out.println("Message ID: " + messageId);37        pulsarClient.close();38        pulsarContainer.stop();39    }40}41import java.io.IOException;42import java.util.concurrent.ExecutionException;43import org.apache.pulsar.client.admin.PulsarAdmin;44import org.apache.pulsar.client.admin.PulsarAdminException;45import org.apache.pulsar.client.api.Consumer;46import org.apache.pulsar.client.api.Message;47import org.apache.pulsar.client.api.MessageId;48import org.apache.puls

withTransactions

Using AI Code Generation

1package com.example;2import org.apache.pulsar.client.api.PulsarClient;3import org.apache.pulsar.client.api.PulsarClientException;4import org.apache.pulsar.client.api.PulsarClientException.AlreadyClosedException;5import org.apache.pulsar.client.api.Schema;6import org.apache.pulsar.client.api.SubscriptionType;7import org.apache.pulsar.client.api.transaction.Transaction;8import org.apache.pulsar.client.api.transaction.TxnID;9import org.apache.pulsar.client.impl.transaction.TransactionImpl;10import org.apache.pulsar.client.impl.transaction.TransactionPendingAckImpl;11import org.apache.pulsar.client.impl.transaction.TransactionPendingAckImpl.PendingAckHandle;12import org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus;13import org.slf4j.Logger;14import org.slf4j.LoggerFactory;15import org.testcontainers.containers.PulsarContainer;16import org.testcontainers.utility.DockerImageName;17import java.util.concurrent.CompletableFuture;18import java.util.concurrent.ExecutionException;19import java.util.concurrent.TimeUnit;20import java.util.concurrent.TimeoutException;21public class PulsarTransactionTest {22    public static void main(String[] args) throws PulsarClientException, AlreadyClosedException, InterruptedException, ExecutionException, TimeoutException {23        PulsarContainer pulsarContainer = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:2.8.0"));24        pulsarContainer.withTransactionCoordinatorEnabled(true);25        pulsarContainer.start();26        String serviceUrl = pulsarContainer.getHttpServiceUrl();27        String brokerUrl = pulsarContainer.getBrokerServiceUrl();28        PulsarClient client = PulsarClient.builder()29                .serviceUrl(serviceUrl)30                .build();31        Transaction transaction = client.newTransaction()32                .withTransactionTimeout(10, TimeUnit.SECONDS)33                .build()34                .get();35        TransactionImpl transactionImpl = (TransactionImpl) transaction;36        TxnID txnID = transactionImpl.getTxnID();37        TransactionCoordinatorStatus status = transactionImpl.getTransactionCoordinatorStatus();38        TransactionPendingAckImpl pendingAck = (TransactionPendingAckImpl) transactionImpl.getPendingAck();39        PendingAckHandle pendingAckHandle = pendingAck.getPendingAckHandle();40        CompletableFuture<Void> completableFuture = pendingAckHandle.closeAsync();41        completableFuture.get(10, TimeUnit.SECONDS);42        client.newConsumer(Schema.STRING)43                .topic("test")44                .subscriptionType(SubscriptionType.Shared)

withTransactions

Using AI Code Generation

1import org.testcontainers.containers.PulsarContainer;2import org.testcontainers.containers.output.Slf4jLogConsumer;3import org.testcontainers.utility.DockerImageName;4public class PulsarContainerTest {5    public static void main(String[] args) {6        PulsarContainer pulsarContainer = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:2.8.0"));7        pulsarContainer.withLogConsumer(new Slf4jLogConsumer(PulsarContainerTest.class));8        pulsarContainer.start();9        pulsarContainer.stop();10    }11}12import org.testcontainers.containers.PulsarContainer;13import org.testcontainers.containers.output.Slf4jLogConsumer;14import org.testcontainers.utility.DockerImageName;15public class PulsarContainerTest {16    public static void main(String[] args) {17        PulsarContainer pulsarContainer = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:2.8.0"));18        pulsarContainer.withLogConsumer(new Slf4jLogConsumer(PulsarContainerTest.class));19        pulsarContainer.withTransactions();20        pulsarContainer.start();21        pulsarContainer.stop();22    }23}24import org.testcontainers.containers.PulsarContainer;25import org.testcontainers.containers.output.Slf4jLogConsumer;26import org.testcontainers.utility.DockerImageName;27public class PulsarContainerTest {28    public static void main(String[] args) {29        PulsarContainer pulsarContainer = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:2.8.0"));30        pulsarContainer.withLogConsumer(new Slf4jLogConsumer(PulsarContainerTest.class));31        pulsarContainer.withTransactions();32        pulsarContainer.withTransactionCoordinator();33        pulsarContainer.start();34        pulsarContainer.stop();35    }36}37import org.testcontainers.containers.PulsarContainer;38import org.testcontainers.containers.output.Slf4jLogConsumer;39import org.testcontainers.utility

withTransactions

Using AI Code Generation

1import org.apache.pulsar.client.admin.PulsarAdmin;2import org.apache.pulsar.client.admin.PulsarAdminException;3import org.apache.pulsar.client.api.*;4import org.testcontainers.containers.PulsarContainer;5import java.util.ArrayList;6import java.util.List;7import java.util.concurrent.CompletableFuture;8import java.util.concurrent.TimeUnit;9public class 1 {10    public static void main(String[] args) throws PulsarClientException, PulsarAdminException {11        PulsarContainer pulsarContainer = new PulsarContainer();12        pulsarContainer.start();13        String pulsarContainerIpAddress = pulsarContainer.getContainerIpAddress();14        int pulsarContainerPort = pulsarContainer.getMappedPort(PulsarContainer.BROKER_PORT);15        PulsarClient pulsarClient = PulsarClient.builder()16                .serviceUrl(pulsarUrl)17                .build();18        Producer<byte[]> producer = pulsarClient.newProducer()19                .create();20        Consumer<byte[]> consumer = pulsarClient.newConsumer()21                .subscriptionName("my-subscription")22                .subscribe();23        PulsarAdmin pulsarAdmin = PulsarAdmin.builder()24                .build();25        String txnId = "txn-" + System.currentTimeMillis();26        pulsarAdmin.transactions().createTransaction(txnId, 30, TimeUnit.SECONDS);27        List<CompletableFuture<MessageId>> futures = new ArrayList<>();28        for (int i = 0; i < 10; i++) {29            String content = "my-message-" + i;30            futures.add(producer.newMessage()31                    .value(content.getBytes())32                    .property("my-property", "my-value")33                    .property("my-other-property", "my-other-value")34                    .sendAsync());35        }

withTransactions

Using AI Code Generation

1import org.apache.pulsar.client.api.*;2import org.apache.pulsar.client.api.transaction.Transaction;3import org.apache.pulsar.client.impl.transaction.TransactionImpl;4import org.apache.pulsar.common.naming.TopicName;5import org.apache.pulsar.common.schema.SchemaInfo;6import org.apache.pulsar.common.schema.SchemaType;7import org.testcontainers.containers.PulsarContainer;8import java.util.Collections;9import java.util.Map;10import java.util.concurrent.TimeUnit;11public class PulsarContainerTest {12    public static void main(String[] args) throws PulsarClientException {13        PulsarContainer pulsarContainer = new PulsarContainer();14        pulsarContainer.start();15        PulsarClient client = PulsarClient.builder()16                .serviceUrl(pulsarContainer.getPlainTextServiceUrl())17                .build();18        Producer<byte[]> producer = client.newProducer()19                .topic(topicName)20                .enableBatching(false)21                .create();22        Consumer<byte[]> consumer = client.newConsumer()23                .topic(topicName)24                .subscriptionName("test")25                .subscribe();26        Transaction transaction = client.newTransaction()27                .withTransactionTimeout(30, TimeUnit.SECONDS)28                .build().get();29        producer.newMessage(transaction)30                .value("test".getBytes())31                .sendAsync();32        transaction.commit().get();33        Message<byte[]> message = consumer.receive();34        System.out.println(new String(message.getValue()));35        consumer.acknowledge(message);36        producer.close();37        consumer.close();38        client.close();39        pulsarContainer.stop();40    }41}

withTransactions

Using AI Code Generation

1import org.apache.pulsar.client.api.*;2import org.apache.pulsar.client.api.schema.GenericRecord;3import org.apache.pulsar.client.api.schema.Schema;4import org.apache.pulsar.client.api.schema.SchemaDefinition;5import org.testcontainers.containers.PulsarContainer;6import org.testcontainers.utility.DockerImageName;7import java.util.concurrent.TimeUnit;8public class Test {9    public static void main(String[] args) throws PulsarClientException {10        PulsarContainer pulsarContainer = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:2.7.2"));11        pulsarContainer.start();12        PulsarClient pulsarClient = PulsarClient.builder()13                .serviceUrl(pulsarContainer.getPulsarBrokerUrl())14                .build();15        SchemaDefinition schemaDefinition = SchemaDefinition.builder()16                .withJsonDef("{\"type\":\"record\",\"name\":\"myrecord\",\"fields\":[{\"name\":\"f1\",\"type\":\"string\"}]}")17                .withAlwaysAllowNull(false)18                .build();19        Schema<GenericRecord> schema = Schema.generic(schemaDefinition);20        pulsarContainer.withTopics(21        Producer<GenericRecord> producer1 = pulsarClient.newProducer(schema)22                .topic("my-topic-1")23                .create();24        for (int i = 0; i < 10; i++) {25            GenericRecord record = schema.newRecordBuilder()26                    .set("f1", "value" + i)27                    .build();28            producer1.send(record);29        }30        Producer<GenericRecord> producer2 = pulsarClient.newProducer(schema)31                .topic("my-topic-2")32                .create();33        for (int i = 0; i < 10; i++) {34            GenericRecord record = schema.newRecordBuilder()35                    .set("f1", "value" +

withTransactions

Using AI Code Generation

1import org.apache.pulsar.client.admin.PulsarAdmin;2import org.apache.pulsar.client.admin.PulsarAdminException;3import org.apache.pulsar.client.admin.Transaction;4import org.apache.pulsar.client.api.*;5import org.apache.pulsar.client.impl.conf.ProducerConfigurationData;6import org.apache.pulsar.common.naming.TopicName;7import org.apache.pulsar.common.policies.data.TransactionCoordinatorStatus;8import org.apache.pulsar.common.policies.data.TransactionInBufferStats;9import org.apache.pulsar.common.policies.data.TransactionInPendingAckStats;10import org.apache.pulsar.common.policies.data.TransactionMetadata;11import org.testcontainers.containers.PulsarContainer;12import org.testcontainers.utility.DockerImageName;13import java.io.IOException;14import java.net.MalformedURLException;15import java.util.Arrays;16import java.util.List;17import java.util.Map;18import java.util.concurrent.TimeUnit;19public class CreateTransaction {20    public static void main(String[] args) throws PulsarClientException, InterruptedException, PulsarAdminException, IOException {21        PulsarContainer pulsarContainer = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:latest"));22        pulsarContainer.start();23        String serviceUrl = pulsarContainer.getHttpServiceUrl();24        PulsarAdmin pulsarAdmin = PulsarAdmin.builder()25                .serviceHttpUrl(serviceUrl)26                .build();27        Map<String, TransactionCoordinatorStatus> transactionCoordinatorStatusMap = pulsarAdmin.brokerStats().getTransactionCoordinatorStatus();28        Map<String, TransactionMetadata> transactionMetadataMap = pulsarAdmin.brokerStats().getTransactionMetadata();29        Map<String, TransactionInBufferStats> transactionInBufferStatsMap = pulsarAdmin.brokerStats().getTransactionInBufferStats();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.