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

Copied to Clipboard!

How to use receive method of com.consol.citrus.jms.endpoint.JmsTopicSubscriber class

Best Citrus code snippet using com.consol.citrus.jms.endpoint.JmsTopicSubscriber.receive

Source:JmsTopicSubscriberTest.java

...94        endpointConfiguration.setPubSubDomain(true);95        endpointConfiguration.setAutoStart(true);96        endpointConfiguration.setConnectionFactory(topicConnectionFactory);97        endpointConfiguration.setDestinationName("JMS.Topic.Test");98        when(topicSubscriber.receive()).thenReturn(new TextMessageImpl("Foo1", Collections.emptyMap()))99                                       .thenReturn(new TextMessageImpl("Foo2", Collections.emptyMap()))100                                       .thenReturn(new TextMessageImpl("Foo3", Collections.emptyMap()))101                                       .thenReturn(null);102        JmsEndpoint jmsEndpoint = new JmsEndpoint(endpointConfiguration);103        JmsConsumer consumer = (JmsConsumer) jmsEndpoint.createConsumer();104        Assert.assertTrue(consumer instanceof JmsTopicSubscriber);105        JmsTopicSubscriber jmsTopicSubscriber = (JmsTopicSubscriber) consumer;106        Assert.assertTrue(jmsTopicSubscriber.isRunning());107        Assert.assertEquals(consumer.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo1");108        Assert.assertEquals(consumer.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo2");109        Assert.assertEquals(consumer.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo3");110    }111    @Test112    public void testSubscriberWithTopicDestination() throws JMSException {113        JmsEndpointConfiguration endpointConfiguration = new JmsEndpointConfiguration();114        endpointConfiguration.setPubSubDomain(true);115        endpointConfiguration.setAutoStart(true);116        endpointConfiguration.setConnectionFactory(topicConnectionFactory);117        endpointConfiguration.setDestination(topic);118        when(topicSubscriber.receive()).thenReturn(new TextMessageImpl("Foo1", Collections.emptyMap()))119                                       .thenReturn(null);120        JmsEndpoint jmsEndpoint = new JmsEndpoint(endpointConfiguration);121        JmsTopicSubscriber jmsTopicSubscriber = (JmsTopicSubscriber) jmsEndpoint.createConsumer();122        Assert.assertEquals(jmsTopicSubscriber.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo1");123    }124    @Test125    public void testSubscriberWithJmsTemplate() throws JMSException {126        JmsEndpointConfiguration endpointConfiguration = new JmsEndpointConfiguration();127        endpointConfiguration.setPubSubDomain(true);128        endpointConfiguration.setAutoStart(true);129        endpointConfiguration.setJmsTemplate(jmsTemplate);130        when(topicSubscriber.receive()).thenReturn(new TextMessageImpl("Foo1", Collections.emptyMap()))131                                       .thenReturn(null);132        JmsEndpoint jmsEndpoint = new JmsEndpoint(endpointConfiguration);133        JmsTopicSubscriber jmsTopicSubscriber = (JmsTopicSubscriber) jmsEndpoint.createConsumer();134        Assert.assertEquals(jmsTopicSubscriber.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo1");135    }136    @Test137    public void testSubscriberStop() throws JMSException, InterruptedException {138        JmsEndpointConfiguration endpointConfiguration = new JmsEndpointConfiguration();139        endpointConfiguration.setPubSubDomain(true);140        endpointConfiguration.setAutoStart(true);141        endpointConfiguration.setConnectionFactory(topicConnectionFactory);142        endpointConfiguration.setDestinationName("JMS.Topic.Test");143        when(topicSubscriber.receive()).thenReturn(new TextMessageImpl("Foo1", Collections.emptyMap()))144                .thenReturn(new TextMessageImpl("Foo2", Collections.emptyMap()))145                .thenReturn(new TextMessageImpl("Foo3", Collections.emptyMap()))146                .thenReturn(null);147        JmsEndpoint jmsEndpoint = new JmsEndpoint(endpointConfiguration);148        JmsTopicSubscriber jmsTopicSubscriber = (JmsTopicSubscriber) jmsEndpoint.createConsumer();149        Assert.assertEquals(jmsTopicSubscriber.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo1");150        Thread.sleep(1000L);151        jmsTopicSubscriber.stop();152        Assert.assertEquals(jmsTopicSubscriber.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo2");153        Assert.assertEquals(jmsTopicSubscriber.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo3");154    }155    @Test156    public void testDurableSubscriber() throws JMSException {157        JmsEndpointConfiguration endpointConfiguration = new JmsEndpointConfiguration();158        endpointConfiguration.setPubSubDomain(true);159        endpointConfiguration.setAutoStart(true);160        endpointConfiguration.setDurableSubscription(true);161        endpointConfiguration.setConnectionFactory(topicConnectionFactory);162        endpointConfiguration.setDestinationName("JMS.Topic.Test");163        when(topicSubscriber.receive()).thenReturn(new TextMessageImpl("Foo1", Collections.emptyMap()))164                .thenReturn(new TextMessageImpl("Foo2", Collections.emptyMap()))165                .thenReturn(new TextMessageImpl("Foo3", Collections.emptyMap()))166                .thenReturn(null);167        JmsEndpoint jmsEndpoint = new JmsEndpoint(endpointConfiguration);168        jmsEndpoint.setName("jmsTopicEndpoint");169        JmsConsumer consumer = (JmsConsumer) jmsEndpoint.createConsumer();170        Assert.assertTrue(consumer instanceof JmsTopicSubscriber);171        JmsTopicSubscriber jmsTopicSubscriber = (JmsTopicSubscriber) consumer;172        Assert.assertTrue(jmsTopicSubscriber.isRunning());173        Assert.assertEquals(consumer.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo1");174        Assert.assertEquals(consumer.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo2");175        Assert.assertEquals(consumer.receive(context, endpointConfiguration.getTimeout()).getPayload(String.class), "Foo3");176    }177}...

Source:JmsTopicSubscriber.java

...83                topic = (Topic) endpointConfiguration.getJmsTemplate().getDefaultDestination();84            } else if (StringUtils.hasText(endpointConfiguration.getJmsTemplate().getDefaultDestinationName())) {85                topic = session.createTopic(endpointConfiguration.getJmsTemplate().getDefaultDestinationName());86            } else {87                throw new CitrusRuntimeException("Unable to receive message - JMS destination not set");88            }89            TopicSubscriber subscriber;90            if (endpointConfiguration.isDurableSubscription()) {91                log.debug(String.format("Create JMS topic durable subscription '%s'", Optional.ofNullable(endpointConfiguration.getDurableSubscriberName()).orElse(getName())));92                subscriber = session.createDurableSubscriber(topic, Optional.ofNullable(endpointConfiguration.getDurableSubscriberName()).orElse(getName()));93            } else {94                log.debug("Create JMS topic subscription");95                subscriber = session.createSubscriber(topic);96            }97            connection.start();98            started.complete(true);99            while (running) {100                javax.jms.Message event = subscriber.receive();101                if (event != null) {102                    TestContext context = testContextFactory.getObject();103                    Message message = endpointConfiguration.getMessageConverter().convertInbound(event, endpointConfiguration, context);104                    if (log.isDebugEnabled()) {105                        log.debug(String.format("Received topic event '%s'", message.getId()));106                    }107                    messageChannel.createProducer().send(message, context);108                } else {109                    log.warn("Topic subscriber received null message - continue after " + endpointConfiguration.getPollingInterval() + " milliseconds");110                    try {111                        Thread.sleep(endpointConfiguration.getPollingInterval());112                    } catch (InterruptedException e) {113                        log.warn("Interrupted while waiting after null message", e);114                    }115                }116            }117        } catch (RuntimeException e) {118            started.completeExceptionally(e);119            throw e;120        } catch (JMSException e) {121            started.completeExceptionally(e);122        } finally {123            if (connection != null) {124                try {125                    connection.close();126                } catch (JMSException e) {127                    log.warn("Failed to close JMS topic connection", e);128                }129            }130            stopped.complete(true);131        }132    }133    public void start() {134        subscription.execute(this);135        try {136            if (started.get()) {137                log.info("Started JMS topic subscription");138            }139        } catch (InterruptedException | ExecutionException e) {140            log.warn("Failed to wait for topic subscriber to start subscription", e);141        }142    }143    public void stop() {144        running = false;145        try {146            stopped.get(endpointConfiguration.getTimeout(), TimeUnit.MILLISECONDS);147        } catch (InterruptedException | ExecutionException e) {148            log.warn("Failed to wait for topic subscriber to stop gracefully", e);149        } catch (TimeoutException e) {150            log.warn("Timeout while waiting for topic subscriber to stop gracefully", e);151        }152    }153    @Override154    public Message receive(TestContext context, long timeout) {155        return messageChannel.createConsumer().receive(context, timeout);156    }157    @Override158    public Message receive(String selector, TestContext context, long timeout) {159        return messageChannel.createConsumer().receive(selector, context, timeout);160    }161    /**162     * Gets the running.163     *164     * @return165     */166    public boolean isRunning() {167        return running;168    }169}...

receive

Using AI Code Generation

1import com.consol.citrus.annotations.CitrusTest;2import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;3import com.consol.citrus.jms.endpoint.JmsTopicSubscriber;4import org.springframework.beans.factory.annotation.Autowired;5import org.springframework.jms.core.JmsTemplate;6import org.testng.annotations.Test;7public class 3 extends TestNGCitrusTestRunner {8    private JmsTemplate jmsTemplate;9    public void 3() {10        JmsTopicSubscriber jmsTopicSubscriber = new JmsTopicSubscriber();11        jmsTopicSubscriber.setJmsTemplate(jmsTemplate);12        jmsTopicSubscriber.setDestinationName("testTopic");13        receive(jmsTopicSubscriber);14    }15}16import com.consol.citrus.annotations.CitrusTest;17import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;18import com.consol.citrus.jms.endpoint.JmsTopicPublisher;19import org.springframework.beans.factory.annotation.Autowired;20import org.springframework.jms.core.JmsTemplate;21import org.testng.annotations.Test;22public class 4 extends TestNGCitrusTestRunner {23    private JmsTemplate jmsTemplate;24    public void 4() {25        JmsTopicPublisher jmsTopicPublisher = new JmsTopicPublisher();26        jmsTopicPublisher.setJmsTemplate(jmsTemplate);27        jmsTopicPublisher.setDestinationName("testTopic");28        send(jmsTopicPublisher);29    }30}31import com.consol.citrus.annotations.CitrusTest;32import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;33import com.consol.citrus.jms.endpoint.JmsQueuePublisher;34import org.springframework.beans.factory.annotation.Autowired;35import org.springframework.jms.core.JmsTemplate;36import org.testng.annotations.Test;37public class 5 extends TestNGCitrusTestRunner {38    private JmsTemplate jmsTemplate;

receive

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;4import com.consol.citrus.dsl.testng.TestNGCitrusTestDesigner;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.testng.CitrusParameters;7import org.springframework.beans.factory.annotation.Autowired;8import org.springframework.core.io.ClassPathResource;9import org.springframework.jms.core.JmsTemplate;10import org.springframework.jms.core.MessageCreator;11import org.springframework.test.context.ContextConfiguration;12import org.springframework.test.context.TestPropertySource;13import org.springframework.test.context.testng.AbstractTestNGSpringContextTests;14import org.springframework.util.StringUtils;15import org.testng.annotations.Test;16import javax.jms.*;17@ContextConfiguration(classes = {com.consol.citrus.samples.SpringConfig.class})18@TestPropertySource(properties = {"citrus.jms.endpoint.queue.queueName=testQueue",19        "citrus.jms.endpoint.topic.topicName=testTopic"})20public class Test2 extends AbstractTestNGSpringContextTests {21    private JmsTemplate jmsTemplate;22    public void test() {23        variable("queueName", "testQueue");24        variable("topicName", "testTopic");25        receive("jms:topic:{{topicName}}")26                .messageType(MessageType.PLAINTEXT)27                .message()28                .body("Hello World!");29        send("jms:queue:{{queueName}}")30                .messageType(MessageType.PLAINTEXT)31                .message()32                .body("Hello World!");33    }34    public void test2() {35        variable("queueName", "testQueue");36        variable("topicName", "testTopic");37        receive("jms:topic:{{topicName}}")38                .messageType(MessageType.PLAINTEXT)39                .message()40                .body("Hello World!");41        send("jms:queue:{{queueName}}")42                .messageType(MessageType.PLAINTEXT)43                .message()44                .body("Hello World!");45    }46    public void test3() {47        variable("queueName", "testQueue");48        variable("topicName", "testTopic");49        receive("jms:topic:{{topicName}}")50                .messageType(MessageType.PLAINTEXT)

receive

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestRunner;4import com.consol.citrus.message.MessageType;5import com.consol.citrus.jms.endpoint.JmsTopicSubscriber;6import org.springframework.beans.factory.annotation.Autowired;7import org.springframework.core.io.ClassPathResource;8import org.springframework.jms.core.JmsTemplate;9import org.testng.annotations.Test;10public class JmsTopicSubscriberReceiveIT extends JUnit4CitrusTestRunner {11    private JmsTemplate jmsTemplate;12    private JmsTopicSubscriber jmsTopicSubscriber;13    public void jmsTopicSubscriberReceive() {14        send("jmsTopicPublisherEndpoint", jmsTemplate, builder -> builder15                .payload(new ClassPathResource("com/consol/citrus/samples/message.xml")));16        receive(jmsTopicSubscriber, builder -> builder17                .payload(new ClassPathResource("com/consol/citrus/samples/message.xml"))18                .messageType(MessageType.XML));19    }20}21package com.consol.citrus.samples;22import com.consol.citrus.annotations.CitrusTest;23import com.consol.citrus.dsl.junit.JUnit4CitrusTestRunner;24import com.consol.citrus.message.MessageType;25import com.consol.citrus.jms.endpoint.JmsTopicSubscriber;26import org.springframework.beans.factory.annotation.Autowired;27import org.springframework.core.io.ClassPathResource;28import org.springframework.jms.core.JmsTemplate;29import org.testng.annotations.Test;30public class JmsTopicSubscriberReceiveIT extends JUnit4CitrusTestRunner {31    private JmsTemplate jmsTemplate;32    private JmsTopicSubscriber jmsTopicSubscriber;33    public void jmsTopicSubscriberReceive() {34        send("jmsTopicPublisherEndpoint", jmsTemplate, builder -> builder35                .payload(new ClassPathResource("com/consol/citrus/samples/message.xml")));36        receive(jmsTopicSubscriber, builder -> builder37                .payload(new ClassPathResource

receive

Using AI Code Generation

1package com.consol.citrus.samples;2import com.consol.citrus.annotations.CitrusXmlTest;3import com.consol.citrus.testng.CitrusParameters;4import org.testng.annotations.Test;5public class JmsTopicSubscriberIT {6    @CitrusParameters({"name"})7    @CitrusXmlTest(name = "JmsTopicSubscriberIT")8    public void JmsTopicSubscriberIT() {}9}

receive

Using AI Code Generation

1package com.consol.citrus;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.testng.TestNGCitrusTestRunner;4import com.consol.citrus.jms.endpoint.JmsTopicSubscriber;5import com.consol.citrus.message.MessageType;6import com.consol.citrus.testng.CitrusParameters;7import org.springframework.beans.factory.annotation.Autowired;8import org.springframework.beans.factory.annotation.Qualifier;9import org.springframework.context.annotation.Bean;10import org.springframework.context.annotation.Configuration;11import org.springframework.context.annotation.Import;12import org.springframework.jms.core.JmsTemplate;13import org.springframework.jms.core.MessageCreator;14import org.springframework.jms.support.converter.MessageConverter;15import org.testng.annotations.Test;16import javax.jms.JMSException;17import javax.jms.Message;18import javax.jms.Session;19public class JMSReceiveTest extends TestNGCitrusTestRunner {20    @Qualifier("jmsTopicSubscriber")21    private JmsTopicSubscriber jmsTopicSubscriber;22    public void testReceive() {23        echo("Starting the test");24        receive(jmsTopicSubscriber)25                .messageType(MessageType.XML)26                .payload("<message>Message 1</message>");27        echo("Message received");28    }29    @Import(DefaultTestConfig.class)30    public static class Config {31        public JmsTopicSubscriber jmsTopicSubscriber() {32            JmsTopicSubscriber jmsTopicSubscriber = new JmsTopicSubscriber();33            jmsTopicSubscriber.setTopicName("test.topic");34            jmsTopicSubscriber.setConnectionFactory(connectionFactory());35            return jmsTopicSubscriber;36        }37        public JmsTemplate jmsTemplate() {38            JmsTemplate jmsTemplate = new JmsTemplate();39            jmsTemplate.setConnectionFactory(connectionFactory());40            jmsTemplate.setDefaultDestinationName("test.topic");41            return jmsTemplate;42        }43        public MessageConverter messageConverter() {44            return new MessageConverter() {45                public Message toMessage(Object object, Session session) throws JMSException {46                    return session.createTextMessage((String) object);47                }48                public Object fromMessage(Message message) throws JMSException {49                    return message;50                }51            };52        }53    }54}

receive

Using AI Code Generation

1package com.consol.citrus.samples.jms;2import com.consol.citrus.annotations.CitrusTest;3import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;4import com.consol.citrus.jms.endpoint.JmsTopicSubscriber;5import com.consol.citrus.message.MessageType;6import org.apache.activemq.ActiveMQConnectionFactory;7import org.junit.Test;8import org.springframework.context.annotation.Bean;9import org.springframework.context.annotation.Configuration;10import org.springframework.jms.core.JmsTemplate;11import javax.jms.ConnectionFactory;12public class JmsTopicSubscriberIT extends JUnit4CitrusTestDesigner {13    public void JmsTopicSubscriberIT() {14        variable("topicName", "citrus:randomNumber(5)");15        echo("Creating topic: '${topicName}'");16        send("jms:topic:ActiveMQ.Advisory.Topic?connectionFactory=topicConnectionFactory")17                .header("JMSType", "ADVISORY_TOPIC");18        echo("Publishing message to topic: '${topicName}'");19        send("jms:topic:${topicName}?connectionFactory=topicConnectionFactory")20                .payload("<testRequestMessage><text>Hello JMS topic!</text></testRequestMessage>");21        echo("Receiving message from topic: '${topicName}'");22        receive("jms:topic:${topicName}?connectionFactory=topicConnectionFactory")23                .messageType(MessageType.XML)24                .payload("<testRequestMessage><text>Hello JMS topic!</text></testRequestMessage>");25    }26    public static class JmsTopicSubscriberITConfig {27        public ConnectionFactory topicConnectionFactory() {28        }29        public JmsTemplate jmsTopicTemplate() {30            JmsTemplate jmsTemplate = new JmsTemplate();31            jmsTemplate.setConnectionFactory(topicConnectionFactory());32            jmsTemplate.setPubSubDomain(true);33            return jmsTemplate;34        }35    }36}

receive

Using AI Code Generation

1public class 3 extends TestCase {2    public void 3() {3        variable("queueName", "test.queue");4        variable("replyQueue", "test.queue.reply");5        variable("message", "Hello Citrus!");6        variable("correlationId", "1234567890");7        variable("timeout", "5000");8        variable("jmsConnectionFactory", "jmsConnectionFactory");9        variable("jmsDestinationName", "test.queue");10        variable("jmsDestinationType", "queue");11        variable("jmsMessageConverter", "jmsMessageConverter");12        variable("jmsMessageSelector", "JMSCorrelationID = '1234567890'");13        variable("jmsReceiveTimeout", "5000");14        variable("jmsPubSubDomain", "false");15        variable("jmsSubscriptionDurable", "false");16        variable("jmsSubscriptionName", "testSubscription");17        variable("jmsTimeToLive", "1000");18        variable("jmsPriority", "4");19        variable("jmsDeliveryMode", "PERSISTENT");20        variable("jmsExplicitQosEnabled", "true");21        variable("jmsReplyDestination", "test.queue.reply");22        variable("jmsReplyDestinationType", "queue");23        variable("jmsReplyMessageConverter", "jmsReplyMessageConverter");24        variable("jmsReplyPubSubDomain", "false");25        variable("jmsReplyTimeToLive", "1000");26        variable("jmsReplyPriority", "4");27        variable("jmsReplyDeliveryMode", "PERSISTENT");28        variable("jmsReplyExplicitQosEnabled", "true");29        variable("jmsReplyCorrelator", "jmsReplyCorrelator");30        variable("jmsReplyCorrelatorType", "header");31        variable("jmsReplyCorrelatorHeaderName", "JMSCorrelationID");32        variable("jmsReplyCorrelatorExpression", "correlationId");33        variable("jmsReplyCorrelatorTimeout", "5000");34        variable("jmsReplyCorrelatorRetryInterval", "1000");35        variable("jmsReplyCorrelatorRetryCount", "5");36        variable("jmsReplyCorrelatorRetryMessageSelector", "JMSCorrelationID = '1234567890'");37        variable("jmsReplyCorrelatorRetryMessageSelector

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.