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 Github

copy

Full Screen

...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}...

Full Screen

Full Screen

Source:JmsTopicSubscriber.java Github

copy

Full Screen

...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}...

Full Screen

Full Screen

receive

Using AI Code Generation

copy

Full Screen

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;

Full Screen

Full Screen

receive

Using AI Code Generation

copy

Full Screen

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)

Full Screen

Full Screen

receive

Using AI Code Generation

copy

Full Screen

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

Full Screen

Full Screen

receive

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

receive

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

receive

Using AI Code Generation

copy

Full Screen

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}

Full Screen

Full Screen

receive

Using AI Code Generation

copy

Full Screen

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

Full Screen

Full Screen

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.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Citrus automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in JmsTopicSubscriber

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful