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

Copied to Clipboard!

How to use VertxSyncEndpointConfiguration class of com.consol.citrus.vertx.endpoint package

Best Citrus code snippet using com.consol.citrus.vertx.endpoint.VertxSyncEndpointConfiguration

Source:VertxSyncEndpointTest.java

...48    }49    @Test50    public void testVertxSyncEndpointProducer() {51        String eventBusAddress = "news-feed";52        VertxSyncEndpointConfiguration endpointConfiguration = new VertxSyncEndpointConfiguration();53        endpointConfiguration.setAddress(eventBusAddress);54        VertxSyncEndpoint vertxEndpoint = new VertxSyncEndpoint(endpointConfiguration);55        vertxEndpoint.setVertxInstanceFactory(instanceFactory);56        Message requestMessage = new DefaultMessage("Hello from Citrus!");57        reset(vertx, eventBus, messageMock, asyncResult);58        when(asyncResult.result()).thenReturn(messageMock);59        when(vertx.eventBus()).thenReturn(eventBus);60        doAnswer(new Answer<EventBus>() {61            @Override62            public EventBus answer(InvocationOnMock invocation) throws Throwable {63                Handler handler = (Handler) invocation.getArguments()[2];64                handler.handle(asyncResult);65                return eventBus;66            }67        }).when(eventBus).send(eq(eventBusAddress), eq(requestMessage.getPayload()), any(Handler.class));68        when(messageMock.body()).thenReturn("Hello from Vertx!");69        when(messageMock.address()).thenReturn(eventBusAddress);70        when(messageMock.replyAddress()).thenReturn("replyAddress");71        vertxEndpoint.createProducer().send(requestMessage, context);72        Message reply = vertxEndpoint.createConsumer().receive(context, 5000L);73        Assert.assertEquals(reply.getPayload(), "Hello from Vertx!");74        Assert.assertEquals(reply.getHeader(CitrusVertxMessageHeaders.VERTX_ADDRESS), eventBusAddress);75        Assert.assertEquals(reply.getHeader(CitrusVertxMessageHeaders.VERTX_REPLY_ADDRESS), "replyAddress");76    }77    @Test78    public void testVertxSyncEndpointConsumer() {79        String eventBusAddress = "news-feed";80        VertxSyncEndpointConfiguration endpointConfiguration = new VertxSyncEndpointConfiguration();81        endpointConfiguration.setAddress(eventBusAddress);82        VertxSyncEndpoint vertxEndpoint = new VertxSyncEndpoint(endpointConfiguration);83        vertxEndpoint.setVertxInstanceFactory(instanceFactory);84        Message replyMessage = new DefaultMessage("Hello from Citrus!");85        reset(vertx, eventBus, messageConsumer, messageMock);86        when(messageMock.body()).thenReturn("Hello from Vertx!");87        when(messageMock.address()).thenReturn(eventBusAddress);88        when(messageMock.replyAddress()).thenReturn("replyAddress");89        when(vertx.eventBus()).thenReturn(eventBus);90        doAnswer(new Answer<MessageConsumer>() {91            @Override92            public MessageConsumer answer(InvocationOnMock invocation) throws Throwable {93                Handler handler = (Handler) invocation.getArguments()[1];94                handler.handle(messageMock);95                return messageConsumer;96            }97        }).when(eventBus).consumer(eq(eventBusAddress), any(Handler.class));98        when(eventBus.send("replyAddress", replyMessage.getPayload())).thenReturn(eventBus);99        Message receivedMessage = vertxEndpoint.createConsumer().receive(context, endpointConfiguration.getTimeout());100        Assert.assertEquals(receivedMessage.getPayload(), "Hello from Vertx!");101        Assert.assertEquals(receivedMessage.getHeader(CitrusVertxMessageHeaders.VERTX_ADDRESS), eventBusAddress);102        Assert.assertEquals(receivedMessage.getHeader(CitrusVertxMessageHeaders.VERTX_REPLY_ADDRESS), "replyAddress");103        vertxEndpoint.createProducer().send(replyMessage, context);104        verify(messageConsumer).unregister();105    }106    @Test107    public void testVertxSyncEndpointWithOutboundMessageListeners() {108        String eventBusAddress = "news-feed";109        VertxSyncEndpointConfiguration endpointConfiguration = new VertxSyncEndpointConfiguration();110        endpointConfiguration.setAddress(eventBusAddress);111        VertxSyncEndpoint vertxEndpoint = new VertxSyncEndpoint(endpointConfiguration);112        vertxEndpoint.setVertxInstanceFactory(instanceFactory);113        Message requestMessage = new DefaultMessage("Hello from Citrus!");114        context.setMessageListeners(messageListeners);115        reset(vertx, eventBus, messageListeners);116        when(vertx.eventBus()).thenReturn(eventBus);117        when(eventBus.send(eq(eventBusAddress), eq(requestMessage.getPayload()), any(Handler.class))).thenReturn(eventBus);118        when(messageListeners.isEmpty()).thenReturn(false);119        vertxEndpoint.createProducer().send(requestMessage, context);120        verify(messageListeners).onOutboundMessage(requestMessage, context);121    }122}...

Source:VertxSyncEndpoint.java

...27    /**28     * Default constructor initializing endpoint.29     */30    public VertxSyncEndpoint() {31        super(new VertxSyncEndpointConfiguration());32    }33    /**34     * Constructor using endpoint configuration.35     * @param endpointConfiguration36     */37    public VertxSyncEndpoint(VertxSyncEndpointConfiguration endpointConfiguration) {38        super(endpointConfiguration);39    }40    @Override41    public VertxSyncEndpointConfiguration getEndpointConfiguration() {42        return (VertxSyncEndpointConfiguration) super.getEndpointConfiguration();43    }44    @Override45    public Consumer createConsumer() {46        if (vertxSyncMessageProducer != null) {47            return vertxSyncMessageProducer;48        }49        if (vertxSyncMessageConsumer == null) {50            vertxSyncMessageConsumer = new VertxSyncConsumer(getConsumerName(),51                    getVertxInstanceFactory().newInstance(getEndpointConfiguration()),52                    getEndpointConfiguration());53        }54        return vertxSyncMessageConsumer;55    }56    @Override...

Source:VertxSyncEndpointParser.java

...17import com.consol.citrus.config.util.BeanDefinitionParserUtils;18import com.consol.citrus.endpoint.Endpoint;19import com.consol.citrus.endpoint.EndpointConfiguration;20import com.consol.citrus.vertx.endpoint.VertxSyncEndpoint;21import com.consol.citrus.vertx.endpoint.VertxSyncEndpointConfiguration;22import org.springframework.beans.factory.support.BeanDefinitionBuilder;23import org.springframework.beans.factory.xml.ParserContext;24import org.w3c.dom.Element;25/**26 * @author Christoph Deppisch27 * @since 1.4.128 */29public class VertxSyncEndpointParser extends VertxEndpointParser {30    @Override31    protected void parseEndpointConfiguration(BeanDefinitionBuilder endpointConfiguration, Element element, ParserContext parserContext) {32        super.parseEndpointConfiguration(endpointConfiguration, element, parserContext);33        BeanDefinitionParserUtils.setPropertyReference(endpointConfiguration,34                element.getAttribute("message-correlator"), "correlator");35    }36    @Override37    protected Class<? extends Endpoint> getEndpointClass() {38        return VertxSyncEndpoint.class;39    }40    @Override41    protected Class<? extends EndpointConfiguration> getEndpointConfigurationClass() {42        return VertxSyncEndpointConfiguration.class;43    }44}...