KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use CamelSyncEndpointConfiguration class of com.consol.citrus.camel.endpoint package

Best Citrus code snippet using com.consol.citrus.camel.endpoint.CamelSyncEndpointConfiguration

Source:CamelSyncEndpointTest.java

...37    private MessageListeners messageListeners = Mockito.mock(MessageListeners.class);38    @Test39    public void testCamelSyncEndpointProducer() {40        String endpointUri = "direct:news-feed";41        CamelSyncEndpointConfiguration endpointConfiguration = new CamelSyncEndpointConfiguration();42        endpointConfiguration.setCamelContext(camelContext);43        endpointConfiguration.setEndpointUri(endpointUri);44        CamelSyncEndpoint camelEndpoint = new CamelSyncEndpoint(endpointConfiguration);45        Message requestMessage = new com.consol.citrus.message.DefaultMessage("Hello from Citrus!");46        reset(camelContext, producerTemplate);47        when(camelContext.getHeadersMapFactory()).thenReturn(new DefaultHeadersMapFactory());48        when(camelContext.createProducerTemplate()).thenReturn(producerTemplate);49        when(camelContext.getUuidGenerator()).thenReturn(new JavaUuidGenerator());50        DefaultMessage message = new DefaultMessage(camelContext);51        message.setBody("Hello from Camel!");52        message.setHeader("operation", "newsFeed");53        Exchange exchange = new DefaultExchange(camelContext);54        exchange.setIn(message);55        when(producerTemplate.request(eq(endpointUri), any(Processor.class))).thenReturn(exchange);56        camelEndpoint.createProducer().send(requestMessage, context);57        Message reply = camelEndpoint.createConsumer().receive(context, 5000L);58        Assert.assertEquals(reply.getPayload(), "Hello from Camel!");59        Assert.assertEquals(reply.getHeader(CitrusCamelMessageHeaders.EXCHANGE_ID), exchange.getExchangeId());60        Assert.assertNotNull(reply.getHeader(CitrusCamelMessageHeaders.EXCHANGE_PATTERN));61        Assert.assertNotNull(reply.getHeader(CitrusCamelMessageHeaders.EXCHANGE_FAILED));62        Assert.assertEquals(reply.getHeader("operation"), "newsFeed");63    }64    @Test65    public void testCamelSyncEndpointConsumer() {66        String endpointUri = "direct:news-feed";67        CamelSyncEndpointConfiguration endpointConfiguration = new CamelSyncEndpointConfiguration();68        endpointConfiguration.setCamelContext(camelContext);69        endpointConfiguration.setEndpointUri(endpointUri);70        CamelSyncEndpoint camelEndpoint = new CamelSyncEndpoint(endpointConfiguration);71        Message replyMessage = new com.consol.citrus.message.DefaultMessage("Hello from Citrus!")72                                                .setHeader("operation", "hello");73        reset(camelContext, consumerTemplate);74        when(camelContext.createConsumerTemplate()).thenReturn(consumerTemplate);75        when(camelContext.getHeadersMapFactory()).thenReturn(new DefaultHeadersMapFactory());76        when(camelContext.getUuidGenerator()).thenReturn(new JavaUuidGenerator());77        DefaultMessage message = new DefaultMessage(camelContext);78        message.setBody("Hello from Camel!");79        message.setHeader("operation", "newsFeed");80        Exchange exchange = new DefaultExchange(camelContext);81        exchange.setIn(message);82        when(consumerTemplate.receive(endpointUri, endpointConfiguration.getTimeout())).thenReturn(exchange);83        Message receivedMessage = camelEndpoint.createConsumer().receive(context, endpointConfiguration.getTimeout());84        Assert.assertEquals(receivedMessage.getPayload(), "Hello from Camel!");85        Assert.assertEquals(receivedMessage.getHeader("operation"), "newsFeed");86        Assert.assertNotNull(receivedMessage.getHeader(CitrusCamelMessageHeaders.EXCHANGE_ID));87        Assert.assertNotNull(receivedMessage.getHeader(CitrusCamelMessageHeaders.EXCHANGE_PATTERN));88        Assert.assertNotNull(receivedMessage.getHeader(CitrusCamelMessageHeaders.EXCHANGE_FAILED));89        camelEndpoint.createProducer().send(replyMessage, context);90        Assert.assertEquals(exchange.getOut().getBody().toString(), replyMessage.getPayload());91        Assert.assertEquals(exchange.getOut().getHeaders().get("operation"), "hello");92        verify(consumerTemplate).doneUoW(exchange);93    }94    @Test95    public void testCamelSyncEndpointWithMessageListeners() {96        String endpointUri = "direct:news-feed";97        CamelSyncEndpointConfiguration endpointConfiguration = new CamelSyncEndpointConfiguration();98        endpointConfiguration.setCamelContext(camelContext);99        endpointConfiguration.setEndpointUri(endpointUri);100        CamelSyncEndpoint camelEndpoint = new CamelSyncEndpoint(endpointConfiguration);101        Message requestMessage = new com.consol.citrus.message.DefaultMessage("Hello from Citrus!");102        DefaultMessage message = new DefaultMessage(camelContext);103        message.setBody("Hello from Camel!");104        Exchange exchange = new DefaultExchange(camelContext);105        exchange.setIn(message);106        context.setMessageListeners(messageListeners);107        reset(camelContext, producerTemplate, messageListeners);108        when(camelContext.createProducerTemplate()).thenReturn(producerTemplate);109        when(camelContext.getHeadersMapFactory()).thenReturn(new DefaultHeadersMapFactory());110        when(camelContext.getUuidGenerator()).thenReturn(new JavaUuidGenerator());111        when(producerTemplate.request(eq(endpointUri), any(Processor.class))).thenReturn(exchange);...

Source:EndpointConfiguration.java

...15 * limitations under the License.16 */17package org.citrusframework.yaks.standard;18import com.consol.citrus.camel.endpoint.CamelSyncEndpoint;19import com.consol.citrus.camel.endpoint.CamelSyncEndpointConfiguration;20import com.consol.citrus.endpoint.direct.DirectEndpoint;21import com.consol.citrus.endpoint.direct.DirectEndpoints;22import com.consol.citrus.message.DefaultMessage;23import org.apache.camel.CamelContext;24import org.apache.camel.builder.RouteBuilder;25import org.apache.camel.spring.SpringCamelContext;26import org.citrusframework.yaks.message.MessageCreator;27import org.citrusframework.yaks.report.SystemOutTestReporter;28import org.springframework.beans.factory.BeanCreationException;29import org.springframework.context.ApplicationContext;30import org.springframework.context.annotation.Bean;31import org.springframework.context.annotation.Configuration;32import org.springframework.context.annotation.DependsOn;33/**34 * @author Christoph Deppisch35 */36@Configuration37public class EndpointConfiguration {38    private CamelContext camelContext;39    @Bean40    public MessageCreator fooMessage() {41        return () -> new DefaultMessage("Hello from Foo!");42    }43    @Bean44    public DirectEndpoint fooEndpoint() {45        return DirectEndpoints46                          .direct()47                          .asynchronous()48                          .queue("foo")49                          .build();50    }51    @Bean52    @DependsOn("camelContext")53    public CamelSyncEndpoint echoEndpoint() {54        CamelSyncEndpointConfiguration endpointConfiguration = new CamelSyncEndpointConfiguration();55        endpointConfiguration.setCamelContext(camelContext);56        endpointConfiguration.setEndpointUri("direct:echo");57        return new CamelSyncEndpoint(endpointConfiguration);58    }59    @Bean60    public CamelContext camelContext(ApplicationContext applicationContext) {61        camelContext = new SpringCamelContext(applicationContext);62        RouteBuilder routeBuilder = new RouteBuilder(camelContext) {63            @Override64            public void configure() throws Exception {65                from("direct:echo")66                    .transform()67                    .simple("You just said: ${body}");68            }...

Source:CamelSyncEndpoint.java

...27    /**28     * Default constructor initializing endpoint.29     */30    public CamelSyncEndpoint() {31        super(new CamelSyncEndpointConfiguration());32    }33    /**34     * Constructor using endpoint configuration.35     * @param endpointConfiguration36     */37    public CamelSyncEndpoint(CamelSyncEndpointConfiguration endpointConfiguration) {38        super(endpointConfiguration);39    }40    @Override41    public CamelSyncEndpointConfiguration getEndpointConfiguration() {42        return (CamelSyncEndpointConfiguration) super.getEndpointConfiguration();43    }44    @Override45    public Consumer createConsumer() {46        if (camelSyncMessageProducer != null) {47            return camelSyncMessageProducer;48        }49        if (camelSyncMessageConsumer == null) {50            camelSyncMessageConsumer = new CamelSyncConsumer(getConsumerName(), getEndpointConfiguration());51        }52        return camelSyncMessageConsumer;53    }54    @Override55    public Producer createProducer() {56        if (camelSyncMessageConsumer != null) {...