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

Copied to Clipboard!

How to use SendMessageAction method of com.consol.citrus.actions.SendMessageAction class

Best Citrus code snippet using com.consol.citrus.actions.SendMessageAction.SendMessageAction

Source:SendMessageTestRunnerTest.java

...14 * limitations under the License.15 */16package com.consol.citrus.dsl.runner;17import com.consol.citrus.TestCase;18import com.consol.citrus.actions.SendMessageAction;19import com.consol.citrus.container.SequenceAfterTest;20import com.consol.citrus.container.SequenceBeforeTest;21import com.consol.citrus.context.TestContext;22import com.consol.citrus.dsl.TestRequest;23import com.consol.citrus.endpoint.Endpoint;24import com.consol.citrus.message.DefaultMessage;25import com.consol.citrus.message.Message;26import com.consol.citrus.message.MessageHeaders;27import com.consol.citrus.message.MessageType;28import com.consol.citrus.messaging.Producer;29import com.consol.citrus.report.TestActionListeners;30import com.consol.citrus.testng.AbstractTestNGUnitTest;31import com.consol.citrus.validation.builder.AbstractMessageContentBuilder;32import com.consol.citrus.validation.builder.PayloadTemplateMessageBuilder;33import com.consol.citrus.validation.builder.StaticMessageContentBuilder;34import com.consol.citrus.validation.json.JsonPathMessageConstructionInterceptor;35import com.consol.citrus.validation.json.JsonPathVariableExtractor;36import com.consol.citrus.validation.xml.XpathMessageConstructionInterceptor;37import com.consol.citrus.validation.xml.XpathPayloadVariableExtractor;38import com.consol.citrus.variable.MessageHeaderVariableExtractor;39import com.consol.citrus.variable.dictionary.DataDictionary;40import com.consol.citrus.variable.dictionary.json.JsonMappingDataDictionary;41import org.mockito.Mockito;42import org.springframework.context.ApplicationContext;43import org.springframework.core.io.Resource;44import org.springframework.oxm.Marshaller;45import org.springframework.oxm.xstream.XStreamMarshaller;46import org.springframework.util.StringUtils;47import org.testng.Assert;48import org.testng.annotations.BeforeClass;49import org.testng.annotations.Test;50import java.io.ByteArrayInputStream;51import java.io.IOException;52import java.util.Collections;53import java.util.HashMap;54import static org.mockito.Mockito.any;55import static org.mockito.Mockito.doAnswer;56import static org.mockito.Mockito.reset;57import static org.mockito.Mockito.when;58/**59 * @author Christoph Deppisch60 * @since 2.361 */62public class SendMessageTestRunnerTest extends AbstractTestNGUnitTest {63    64    private Endpoint messageEndpoint = Mockito.mock(Endpoint.class);65    private Producer messageProducer = Mockito.mock(Producer.class);66    private ApplicationContext applicationContextMock = Mockito.mock(ApplicationContext.class);67    private Resource resource = Mockito.mock(Resource.class);68    private XStreamMarshaller marshaller = new XStreamMarshaller();69    @BeforeClass70    public void prepareMarshaller() {71        marshaller.getXStream().processAnnotations(TestRequest.class);72    }73    @Test74    public void testSendBuilderWithMessageInstance() {75        reset(messageEndpoint, messageProducer);76        when(messageEndpoint.createProducer()).thenReturn(messageProducer);77        when(messageEndpoint.getActor()).thenReturn(null);78        doAnswer(invocation -> {79            Message message = (Message) invocation.getArguments()[0];80            Assert.assertEquals(message.getPayload(String.class), "Foo");81            Assert.assertNotNull(message.getHeader("operation"));82            Assert.assertEquals(message.getHeader("operation"), "foo");83            return null;84        }).when(messageProducer).send(any(Message.class), any(TestContext.class));85        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {86            @Override87            public void execute() {88                send(builder -> builder.endpoint(messageEndpoint)89                        .message(new DefaultMessage("Foo").setHeader("operation", "foo"))90                            .header("additional", "additionalValue"));91            }92        };93        final TestCase test = builder.getTestCase();94        Assert.assertEquals(test.getActionCount(), 1);95        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);96        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));97        Assert.assertEquals(action.getName(), "send");98        Assert.assertEquals(action.getEndpoint(), messageEndpoint);99        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);100        final StaticMessageContentBuilder messageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();101        Assert.assertEquals(messageBuilder.getMessage().getPayload(String.class), "Foo");102        Assert.assertEquals(messageBuilder.getMessage().getHeader("operation"), "foo");103        Assert.assertEquals(messageBuilder.getMessageHeaders().get("additional"), "additionalValue");104    }105    @Test106    public void testSendBuilderWithObjectMessageInstance() {107        reset(messageEndpoint, messageProducer);108        when(messageEndpoint.createProducer()).thenReturn(messageProducer);109        when(messageEndpoint.getActor()).thenReturn(null);110        doAnswer(invocation -> {111            Message message = (Message) invocation.getArguments()[0];112            Assert.assertEquals(message.getPayload(Integer.class), new Integer(10));113            Assert.assertNotNull(message.getHeader("operation"));114            Assert.assertEquals(message.getHeader("operation"), "foo");115            return null;116        }).when(messageProducer).send(any(Message.class), any(TestContext.class));117        final Message message = new DefaultMessage(10).setHeader("operation", "foo");118        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {119            @Override120            public void execute() {121                send(builder -> builder.endpoint(messageEndpoint)122                        .message(message));123            }124        };125        final TestCase test = builder.getTestCase();126        Assert.assertEquals(test.getActionCount(), 1);127        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);128        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));129        Assert.assertEquals(action.getName(), "send");130        Assert.assertEquals(action.getEndpoint(), messageEndpoint);131        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);132        final StaticMessageContentBuilder messageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();133        Assert.assertEquals(messageBuilder.getMessage().getPayload(), 10);134        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);135        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), message.getHeaders().size());136        Assert.assertEquals(messageBuilder.getMessage().getHeader(MessageHeaders.ID), message.getHeader(MessageHeaders.ID));137        Assert.assertEquals(messageBuilder.getMessage().getHeader("operation"), "foo");138        final Message constructed = messageBuilder.buildMessageContent(new TestContext(), MessageType.PLAINTEXT.name());139        Assert.assertEquals(constructed.getHeaders().size(), message.getHeaders().size() + 1);140        Assert.assertEquals(constructed.getHeader("operation"), "foo");141        Assert.assertNotEquals(constructed.getHeader(MessageHeaders.ID), message.getHeader(MessageHeaders.ID));142    }143    @Test144    public void testSendBuilderWithObjectMessageInstanceAdditionalHeader() {145        reset(messageEndpoint, messageProducer);146        when(messageEndpoint.createProducer()).thenReturn(messageProducer);147        when(messageEndpoint.getActor()).thenReturn(null);148        doAnswer(invocation -> {149            Message message = (Message) invocation.getArguments()[0];150            Assert.assertEquals(message.getPayload(Integer.class), new Integer(10));151            Assert.assertNotNull(message.getHeader("operation"));152            Assert.assertEquals(message.getHeader("operation"), "foo");153            Assert.assertNotNull(message.getHeader("additional"));154            Assert.assertEquals(message.getHeader("additional"), "new");155            return null;156        }).when(messageProducer).send(any(Message.class), any(TestContext.class));157        final Message message = new DefaultMessage(10).setHeader("operation", "foo");158        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {159            @Override160            public void execute() {161                send(builder -> builder.endpoint(messageEndpoint)162                        .message(message)163                        .header("additional", "new"));164            }165        };166        final TestCase test = builder.getTestCase();167        Assert.assertEquals(test.getActionCount(), 1);168        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);169        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));170        Assert.assertEquals(action.getName(), "send");171        Assert.assertEquals(action.getEndpoint(), messageEndpoint);172        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);173        final StaticMessageContentBuilder messageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();174        Assert.assertEquals(messageBuilder.getMessage().getPayload(), 10);175        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 1L);176        Assert.assertEquals(messageBuilder.getMessageHeaders().get("additional"), "new");177        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), message.getHeaders().size());178        Assert.assertEquals(messageBuilder.getMessage().getHeader(MessageHeaders.ID), message.getHeader(MessageHeaders.ID));179        Assert.assertEquals(messageBuilder.getMessage().getHeader("operation"), "foo");180        final Message constructed = messageBuilder.buildMessageContent(new TestContext(), MessageType.PLAINTEXT.name());181        Assert.assertEquals(constructed.getHeaders().size(), message.getHeaders().size() + 2);182        Assert.assertEquals(constructed.getHeader("operation"), "foo");183        Assert.assertEquals(constructed.getHeader("additional"), "new");184    }185    @Test186    public void testSendBuilderWithPayloadModel() {187        reset(applicationContextMock, messageEndpoint, messageProducer);188        when(messageEndpoint.createProducer()).thenReturn(messageProducer);189        when(messageEndpoint.getActor()).thenReturn(null);190        doAnswer(invocation -> {191            Message message = (Message) invocation.getArguments()[0];192            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");193            return null;194        }).when(messageProducer).send(any(Message.class), any(TestContext.class));195        when(applicationContextMock.getBean(TestContext.class)).thenReturn(applicationContext.getBean(TestContext.class));196        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());197        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());198        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());199        when(applicationContextMock.getBeansOfType(Marshaller.class)).thenReturn(Collections.singletonMap("marshaller", marshaller));200        when(applicationContextMock.getBean(Marshaller.class)).thenReturn(marshaller);201        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContextMock, context) {202            @Override203            public void execute() {204                send(builder -> builder.endpoint(messageEndpoint)205                        .payloadModel(new TestRequest("Hello Citrus!")));206            }207        };208        final TestCase test = builder.getTestCase();209        Assert.assertEquals(test.getActionCount(), 1);210        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);211        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));212        Assert.assertEquals(action.getName(), "send");213        Assert.assertEquals(action.getEndpoint(), messageEndpoint);214        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);215        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();216        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");217        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);218    }219    @Test220    public void testSendBuilderWithPayloadModelExplicitMarshaller() {221        reset(messageEndpoint, messageProducer);222        when(messageEndpoint.createProducer()).thenReturn(messageProducer);223        when(messageEndpoint.getActor()).thenReturn(null);224        doAnswer(invocation -> {225            Message message = (Message) invocation.getArguments()[0];226            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");227            return null;228        }).when(messageProducer).send(any(Message.class), any(TestContext.class));229        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {230            @Override231            public void execute() {232                send(builder -> builder.endpoint(messageEndpoint)233                        .payload(new TestRequest("Hello Citrus!"), marshaller));234            }235        };236        final TestCase test = builder.getTestCase();237        Assert.assertEquals(test.getActionCount(), 1);238        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);239        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));240        Assert.assertEquals(action.getName(), "send");241        Assert.assertEquals(action.getEndpoint(), messageEndpoint);242        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);243        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();244        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");245        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);246    }247    @Test248    public void testSendBuilderWithPayloadModelExplicitMarshallerName() {249        reset(applicationContextMock, messageEndpoint, messageProducer);250        when(messageEndpoint.createProducer()).thenReturn(messageProducer);251        when(messageEndpoint.getActor()).thenReturn(null);252        doAnswer(invocation -> {253            Message message = (Message) invocation.getArguments()[0];254            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");255            return null;256        }).when(messageProducer).send(any(Message.class), any(TestContext.class));257        when(applicationContextMock.getBean(TestContext.class)).thenReturn(applicationContext.getBean(TestContext.class));258        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());259        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());260        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());261        when(applicationContextMock.containsBean("myMarshaller")).thenReturn(true);262        when(applicationContextMock.getBean("myMarshaller")).thenReturn(marshaller);263        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContextMock, context) {264            @Override265            public void execute() {266                send(builder -> builder.endpoint(messageEndpoint)267                        .payload(new TestRequest("Hello Citrus!"), "myMarshaller"));268            }269        };270        final TestCase test = builder.getTestCase();271        Assert.assertEquals(test.getActionCount(), 1);272        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);273        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));274        Assert.assertEquals(action.getName(), "send");275        Assert.assertEquals(action.getEndpoint(), messageEndpoint);276        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);277        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();278        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");279        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);280    }281    282    @Test283    public void testSendBuilderWithPayloadData() {284        reset(messageEndpoint, messageProducer);285        when(messageEndpoint.createProducer()).thenReturn(messageProducer);286        when(messageEndpoint.getActor()).thenReturn(null);287        doAnswer(invocation -> {288            Message message = (Message) invocation.getArguments()[0];289            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");290            return null;291        }).when(messageProducer).send(any(Message.class), any(TestContext.class));292        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {293            @Override294            public void execute() {295                send(builder -> builder.endpoint(messageEndpoint)296                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>"));297            }298        };299        final TestCase test = builder.getTestCase();300        Assert.assertEquals(test.getActionCount(), 1);301        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);302        303        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));304        Assert.assertEquals(action.getName(), "send");305        306        Assert.assertEquals(action.getEndpoint(), messageEndpoint);307        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);308        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();309        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");310        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);311    }312    @Test313    public void testSendBuilderWithPayloadResource() throws IOException {314        reset(resource, messageEndpoint, messageProducer);315        when(messageEndpoint.createProducer()).thenReturn(messageProducer);316        when(messageEndpoint.getActor()).thenReturn(null);317        doAnswer(invocation -> {318            Message message = (Message) invocation.getArguments()[0];319            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");320            return null;321        }).when(messageProducer).send(any(Message.class), any(TestContext.class));322        when(resource.getInputStream()).thenReturn(new ByteArrayInputStream("<TestRequest><Message>Hello World!</Message></TestRequest>".getBytes()));323        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {324            @Override325            public void execute() {326                send(builder -> builder.endpoint(messageEndpoint)327                        .payload(resource));328            }329        };330        final TestCase test = builder.getTestCase();331        Assert.assertEquals(test.getActionCount(), 1);332        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);333        334        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));335        Assert.assertEquals(action.getName(), "send");336        337        Assert.assertEquals(action.getEndpoint(), messageEndpoint);338        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);339        340        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();341        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");342        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);343    }344    345    @Test346    public void testSendBuilderWithEndpointName() {347        final TestContext context = applicationContext.getBean(TestContext.class);348        context.setApplicationContext(applicationContextMock);349        reset(applicationContextMock, messageEndpoint, messageProducer);350        when(messageEndpoint.createProducer()).thenReturn(messageProducer);351        when(messageEndpoint.getActor()).thenReturn(null);352        doAnswer(invocation -> {353            Message message = (Message) invocation.getArguments()[0];354            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");355            return null;356        }).when(messageProducer).send(any(Message.class), any(TestContext.class));357        when(applicationContextMock.getBean(TestContext.class)).thenReturn(context);358        when(applicationContextMock.getBean("fooMessageEndpoint", Endpoint.class)).thenReturn(messageEndpoint);359        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());360        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());361        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());362        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContextMock, context) {363            @Override364            public void execute() {365                send(builder -> builder.endpoint("fooMessageEndpoint")366                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>"));367            }368        };369        final TestCase test = builder.getTestCase();370        Assert.assertEquals(test.getActionCount(), 1);371        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);372        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));373        Assert.assertEquals(action.getName(), "send");374        Assert.assertEquals(action.getEndpointUri(), "fooMessageEndpoint");375    }376    377    @Test378    public void testSendBuilderWithHeaders() {379        reset(messageEndpoint, messageProducer);380        when(messageEndpoint.createProducer()).thenReturn(messageProducer);381        when(messageEndpoint.getActor()).thenReturn(null);382        doAnswer(invocation -> {383            Message message = (Message) invocation.getArguments()[0];384            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");385            Assert.assertNotNull(message.getHeader("operation"));386            Assert.assertEquals(message.getHeader("operation"), "foo");387            Assert.assertNotNull(message.getHeader("language"));388            Assert.assertEquals(message.getHeader("language"), "eng");389            return null;390        }).when(messageProducer).send(any(Message.class), any(TestContext.class));391        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {392            @Override393            public void execute() {394                send(builder -> builder.endpoint(messageEndpoint)395                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")396                        .headers(Collections.singletonMap("some", "value"))397                        .header("operation", "foo")398                        .header("language", "eng"));399            }400        };401        final TestCase test = builder.getTestCase();402        Assert.assertEquals(test.getActionCount(), 1);403        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);404        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));405        Assert.assertEquals(action.getName(), "send");406        Assert.assertEquals(action.getEndpoint(), messageEndpoint);407        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);408        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();409        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");410        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 3L);411        Assert.assertEquals(messageBuilder.getMessageHeaders().get("some"), "value");412        Assert.assertEquals(messageBuilder.getMessageHeaders().get("operation"), "foo");413        Assert.assertEquals(messageBuilder.getMessageHeaders().get("language"), "eng");414    }415    416    @Test417    public void testSendBuilderWithHeaderData() {418        reset(messageEndpoint, messageProducer);419        when(messageEndpoint.createProducer()).thenReturn(messageProducer);420        when(messageEndpoint.getActor()).thenReturn(null);421        doAnswer(invocation -> {422            Message message = (Message) invocation.getArguments()[0];423            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");424            Assert.assertNotNull(message.getHeaderData());425            Assert.assertEquals(message.getHeaderData().size(), 1L);426            Assert.assertEquals(message.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo</Value></Header>");427            return null;428        }).when(messageProducer).send(any(Message.class), any(TestContext.class));429        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {430            @Override431            public void execute() {432                send(builder -> builder.endpoint(messageEndpoint)433                     .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")434                     .header("<Header><Name>operation</Name><Value>foo</Value></Header>"));435                436                send(builder -> builder.endpoint(messageEndpoint)437                    .message(new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>"))438                    .header("<Header><Name>operation</Name><Value>foo</Value></Header>"));439            }440        };441        final TestCase test = builder.getTestCase();442        Assert.assertEquals(test.getActionCount(), 2);443        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);444        Assert.assertEquals(test.getActions().get(1).getClass(), SendMessageAction.class);445        446        SendMessageAction action = ((SendMessageAction)test.getActions().get(0));447        Assert.assertEquals(action.getName(), "send");448        449        Assert.assertEquals(action.getEndpoint(), messageEndpoint);450        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);451        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();452        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");453        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);454        Assert.assertEquals(messageBuilder.getHeaderData().size(), 1L);455        Assert.assertEquals(messageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo</Value></Header>");456        Assert.assertEquals(messageBuilder.getHeaderResources().size(), 0L);457        action = ((SendMessageAction)test.getActions().get(1));458        Assert.assertEquals(action.getName(), "send");459        Assert.assertEquals(action.getEndpoint(), messageEndpoint);460        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);461        final StaticMessageContentBuilder staticMessageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();462        Assert.assertEquals(staticMessageBuilder.getMessage().getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");463        Assert.assertEquals(staticMessageBuilder.getMessageHeaders().size(), 0L);464        Assert.assertEquals(staticMessageBuilder.getHeaderData().size(), 1L);465        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo</Value></Header>");466        Assert.assertEquals(staticMessageBuilder.getHeaderResources().size(), 0L);467    }468    @Test469    public void testSendBuilderWithMultipleHeaderData() {470        reset(messageEndpoint, messageProducer);471        when(messageEndpoint.createProducer()).thenReturn(messageProducer);472        when(messageEndpoint.getActor()).thenReturn(null);473        doAnswer(invocation -> {474            Message message = (Message) invocation.getArguments()[0];475            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");476            Assert.assertNotNull(message.getHeaderData());477            Assert.assertEquals(message.getHeaderData().size(), 2L);478            Assert.assertEquals(message.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo1</Value></Header>");479            Assert.assertEquals(message.getHeaderData().get(1), "<Header><Name>operation</Name><Value>foo2</Value></Header>");480            return null;481        }).when(messageProducer).send(any(Message.class), any(TestContext.class));482        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {483            @Override484            public void execute() {485                send(builder -> builder.endpoint(messageEndpoint)486                         .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")487                         .header("<Header><Name>operation</Name><Value>foo1</Value></Header>")488                         .header("<Header><Name>operation</Name><Value>foo2</Value></Header>"));489                send(builder -> builder.endpoint(messageEndpoint)490                    .message(new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>"))491                    .header("<Header><Name>operation</Name><Value>foo1</Value></Header>")492                    .header("<Header><Name>operation</Name><Value>foo2</Value></Header>"));493            }494        };495        final TestCase test = builder.getTestCase();496        Assert.assertEquals(test.getActionCount(), 2);497        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);498        Assert.assertEquals(test.getActions().get(1).getClass(), SendMessageAction.class);499        SendMessageAction action = ((SendMessageAction)test.getActions().get(0));500        Assert.assertEquals(action.getName(), "send");501        Assert.assertEquals(action.getEndpoint(), messageEndpoint);502        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);503        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();504        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");505        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);506        Assert.assertEquals(messageBuilder.getHeaderData().size(), 2L);507        Assert.assertEquals(messageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo1</Value></Header>");508        Assert.assertEquals(messageBuilder.getHeaderData().get(1), "<Header><Name>operation</Name><Value>foo2</Value></Header>");509        Assert.assertEquals(messageBuilder.getHeaderResources().size(), 0L);510        action = ((SendMessageAction)test.getActions().get(1));511        Assert.assertEquals(action.getName(), "send");512        Assert.assertEquals(action.getEndpoint(), messageEndpoint);513        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);514        final StaticMessageContentBuilder staticMessageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();515        Assert.assertEquals(staticMessageBuilder.getMessage().getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");516        Assert.assertEquals(staticMessageBuilder.getMessageHeaders().size(), 0L);517        Assert.assertEquals(staticMessageBuilder.getHeaderData().size(), 2L);518        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo1</Value></Header>");519        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(1), "<Header><Name>operation</Name><Value>foo2</Value></Header>");520        Assert.assertEquals(staticMessageBuilder.getHeaderResources().size(), 0L);521    }522    523    @Test524    public void testSendBuilderWithHeaderDataResource() throws IOException {525        reset(resource, messageEndpoint, messageProducer);526        when(messageEndpoint.createProducer()).thenReturn(messageProducer);527        when(messageEndpoint.getActor()).thenReturn(null);528        doAnswer(invocation -> {529            Message message = (Message) invocation.getArguments()[0];530            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");531            Assert.assertNotNull(message.getHeaderData());532            Assert.assertEquals(message.getHeaderData().size(), 1L);533            Assert.assertEquals(message.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo1</Value></Header>");534            return null;535        }).doAnswer(invocation -> {536            Message message = (Message) invocation.getArguments()[0];537            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");538            Assert.assertNotNull(message.getHeaderData());539            Assert.assertEquals(message.getHeaderData().size(), 1L);540            Assert.assertEquals(message.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo2</Value></Header>");541            return null;542        }).when(messageProducer).send(any(Message.class), any(TestContext.class));543        when(resource.getInputStream()).thenReturn(new ByteArrayInputStream("<Header><Name>operation</Name><Value>foo1</Value></Header>".getBytes()))544                                       .thenReturn(new ByteArrayInputStream("<Header><Name>operation</Name><Value>foo2</Value></Header>".getBytes()));545        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {546            @Override547            public void execute() {548                send(builder -> builder.endpoint(messageEndpoint)549                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")550                        .header(resource));551                send(builder -> builder.endpoint(messageEndpoint)552                        .message(new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>"))553                        .header(resource));554            }555        };556        final TestCase test = builder.getTestCase();557        Assert.assertEquals(test.getActionCount(), 2);558        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);559        Assert.assertEquals(test.getActions().get(1).getClass(), SendMessageAction.class);560        561        SendMessageAction action = ((SendMessageAction)test.getActions().get(0));562        Assert.assertEquals(action.getName(), "send");563        564        Assert.assertEquals(action.getEndpoint(), messageEndpoint);565        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);566        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();567        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");568        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);569        Assert.assertEquals(messageBuilder.getHeaderData().size(), 1L);570        Assert.assertEquals(messageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo1</Value></Header>");571        Assert.assertEquals(messageBuilder.getHeaderResources().size(), 0L);572        action = ((SendMessageAction)test.getActions().get(1));573        Assert.assertEquals(action.getName(), "send");574        Assert.assertEquals(action.getEndpoint(), messageEndpoint);575        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);576        final StaticMessageContentBuilder staticMessageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();577        Assert.assertEquals(staticMessageBuilder.getMessage().getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");578        Assert.assertEquals(staticMessageBuilder.getMessageHeaders().size(), 0L);579        Assert.assertEquals(staticMessageBuilder.getHeaderData().size(), 1L);580        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo2</Value></Header>");581        Assert.assertEquals(staticMessageBuilder.getHeaderResources().size(), 0L);582    }583    584    @Test585    public void testSendBuilderExtractFromPayload() {586        reset(messageEndpoint, messageProducer);587        when(messageEndpoint.createProducer()).thenReturn(messageProducer);588        when(messageEndpoint.getActor()).thenReturn(null);589        doAnswer(invocation -> {590            Message message = (Message) invocation.getArguments()[0];591            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message lang=\"ENG\">Hello World!</Message></TestRequest>");592            return null;593        }).when(messageProducer).send(any(Message.class), any(TestContext.class));594        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {595            @Override596            public void execute() {597                send(builder -> builder.endpoint(messageEndpoint)598                        .payload("<TestRequest><Message lang=\"ENG\">Hello World!</Message></TestRequest>")599                        .extractFromPayload("/TestRequest/Message", "text")600                        .extractFromPayload("/TestRequest/Message/@lang", "language"));601            }602        };603        final TestContext context = builder.getTestContext();604        Assert.assertNotNull(context.getVariable("text"));605        Assert.assertNotNull(context.getVariable("language"));606        Assert.assertEquals(context.getVariable("text"), "Hello World!");607        Assert.assertEquals(context.getVariable("language"), "ENG");608        final TestCase test = builder.getTestCase();609        Assert.assertEquals(test.getActionCount(), 1);610        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);611        612        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));613        Assert.assertEquals(action.getName(), "send");614        615        Assert.assertEquals(action.getEndpoint(), messageEndpoint);616        617        Assert.assertEquals(action.getVariableExtractors().size(), 1);618        Assert.assertTrue(action.getVariableExtractors().get(0) instanceof XpathPayloadVariableExtractor);619        Assert.assertTrue(((XpathPayloadVariableExtractor)action.getVariableExtractors().get(0)).getXpathExpressions().containsKey("/TestRequest/Message"));620        Assert.assertTrue(((XpathPayloadVariableExtractor)action.getVariableExtractors().get(0)).getXpathExpressions().containsKey("/TestRequest/Message/@lang"));621    }622    @Test623    public void testSendBuilderExtractJsonPathFromPayload() {624        reset(messageEndpoint, messageProducer);625        when(messageEndpoint.createProducer()).thenReturn(messageProducer);626        when(messageEndpoint.getActor()).thenReturn(null);627        doAnswer(invocation -> {628            Message message = (Message) invocation.getArguments()[0];629            Assert.assertEquals(message.getPayload(String.class), "{\"text\":\"Hello World!\", \"person\":{\"name\":\"John\",\"surname\":\"Doe\"}, \"index\":5, \"id\":\"x123456789x\"}");630            return null;631        }).when(messageProducer).send(any(Message.class), any(TestContext.class));632        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {633            @Override634            public void execute() {635                send(builder -> builder.endpoint(messageEndpoint)636                        .messageType(MessageType.JSON)637                        .payload("{\"text\":\"Hello World!\", \"person\":{\"name\":\"John\",\"surname\":\"Doe\"}, \"index\":5, \"id\":\"x123456789x\"}")638                        .extractFromPayload("$.text", "text")639                        .extractFromPayload("$.person", "person"));640            }641        };642        final TestContext context = builder.getTestContext();643        Assert.assertNotNull(context.getVariable("text"));644        Assert.assertNotNull(context.getVariable("person"));645        Assert.assertEquals(context.getVariable("text"), "Hello World!");646        Assert.assertTrue(context.getVariable("person").contains("\"John\""));647        final TestCase test = builder.getTestCase();648        Assert.assertEquals(test.getActionCount(), 1);649        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);650        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));651        Assert.assertEquals(action.getName(), "send");652        Assert.assertEquals(action.getEndpoint(), messageEndpoint);653        Assert.assertEquals(action.getVariableExtractors().size(), 1);654        Assert.assertTrue(action.getVariableExtractors().get(0) instanceof JsonPathVariableExtractor);655        Assert.assertTrue(((JsonPathVariableExtractor)action.getVariableExtractors().get(0)).getJsonPathExpressions().containsKey("$.text"));656        Assert.assertTrue(((JsonPathVariableExtractor)action.getVariableExtractors().get(0)).getJsonPathExpressions().containsKey("$.person"));657    }658    659    @Test660    public void testSendBuilderExtractFromHeader() {661        reset(messageEndpoint, messageProducer);662        when(messageEndpoint.createProducer()).thenReturn(messageProducer);663        when(messageEndpoint.getActor()).thenReturn(null);664        doAnswer(invocation -> {665            Message message = (Message) invocation.getArguments()[0];666            Assert.assertEquals(message.getPayload(String.class), "<TestRequest><Message lang=\"ENG\">Hello World!</Message></TestRequest>");667            return null;668        }).when(messageProducer).send(any(Message.class), any(TestContext.class));669        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {670            @Override671            public void execute() {672                send(builder -> builder.endpoint(messageEndpoint)673                        .payload("<TestRequest><Message lang=\"ENG\">Hello World!</Message></TestRequest>")674                        .header("operation", "sayHello")675                        .header("requestId", "123456")676                        .extractFromHeader("operation", "operationHeader")677                        .extractFromHeader("requestId", "id"));678            }679        };680        final TestContext context = builder.getTestContext();681        Assert.assertNotNull(context.getVariable("operationHeader"));682        Assert.assertNotNull(context.getVariable("id"));683        Assert.assertEquals(context.getVariable("operationHeader"), "sayHello");684        Assert.assertEquals(context.getVariable("id"), "123456");685        final TestCase test = builder.getTestCase();686        Assert.assertEquals(test.getActionCount(), 1);687        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);688        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));689        Assert.assertEquals(action.getName(), "send");690        Assert.assertEquals(action.getEndpoint(), messageEndpoint);691        Assert.assertEquals(action.getVariableExtractors().size(), 1);692        Assert.assertTrue(action.getVariableExtractors().get(0) instanceof MessageHeaderVariableExtractor);693        Assert.assertTrue(((MessageHeaderVariableExtractor) action.getVariableExtractors().get(0)).getHeaderMappings().containsKey("operation"));694        Assert.assertTrue(((MessageHeaderVariableExtractor) action.getVariableExtractors().get(0)).getHeaderMappings().containsKey("requestId"));695    }696    @Test697    public void testXpathSupport() {698        reset(messageEndpoint, messageProducer);699        when(messageEndpoint.createProducer()).thenReturn(messageProducer);700        when(messageEndpoint.getActor()).thenReturn(null);701        doAnswer(invocation -> {702            Message message = (Message) invocation.getArguments()[0];703            Assert.assertEquals(StringUtils.trimAllWhitespace(message.getPayload(String.class)),704                    "<?xmlversion=\"1.0\"encoding=\"UTF-8\"?><TestRequest><Messagelang=\"ENG\">HelloWorld!</Message></TestRequest>");705            return null;706        }).when(messageProducer).send(any(Message.class), any(TestContext.class));707        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {708            @Override709            public void execute() {710                send(builder -> builder.endpoint(messageEndpoint)711                        .payload("<TestRequest><Message lang=\"ENG\">?</Message></TestRequest>")712                        .xpath("/TestRequest/Message", "Hello World!"));713            }714        };715        final TestCase test = builder.getTestCase();716        Assert.assertEquals(test.getActionCount(), 1);717        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);718        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));719        Assert.assertEquals(action.getName(), "send");720        Assert.assertEquals(action.getEndpoint(), messageEndpoint);721        Assert.assertTrue(action.getMessageBuilder() instanceof AbstractMessageContentBuilder);722        Assert.assertEquals(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().size(), 1);723        Assert.assertTrue(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0) instanceof XpathMessageConstructionInterceptor);724        Assert.assertEquals(((XpathMessageConstructionInterceptor)((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0)).getXPathExpressions().get("/TestRequest/Message"), "Hello World!");725    }726    @Test727    public void testJsonPathSupport() {728        reset(messageEndpoint, messageProducer);729        when(messageEndpoint.createProducer()).thenReturn(messageProducer);730        when(messageEndpoint.getActor()).thenReturn(null);731        doAnswer(invocation -> {732            Message message = (Message) invocation.getArguments()[0];733            Assert.assertEquals(StringUtils.trimAllWhitespace(message.getPayload(String.class)),734                    "{\"TestRequest\":{\"Message\":\"HelloWorld!\"}}");735            return null;736        }).when(messageProducer).send(any(Message.class), any(TestContext.class));737        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {738            @Override739            public void execute() {740                send(builder -> builder.endpoint(messageEndpoint)741                        .messageType(MessageType.JSON)742                        .payload("{ \"TestRequest\": { \"Message\": \"?\" }}")743                        .jsonPath("$.TestRequest.Message", "Hello World!"));744            }745        };746        final TestCase test = builder.getTestCase();747        Assert.assertEquals(test.getActionCount(), 1);748        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);749        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));750        Assert.assertEquals(action.getName(), "send");751        Assert.assertEquals(action.getEndpoint(), messageEndpoint);752        Assert.assertTrue(action.getMessageBuilder() instanceof AbstractMessageContentBuilder);753        Assert.assertEquals(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().size(), 1);754        Assert.assertTrue(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0) instanceof JsonPathMessageConstructionInterceptor);755        Assert.assertEquals(((JsonPathMessageConstructionInterceptor)((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0)).getJsonPathExpressions().get("$.TestRequest.Message"), "Hello World!");756    }757    @Test758    public void testSendBuilderWithDictionary() {759        final JsonMappingDataDictionary dictionary = new JsonMappingDataDictionary();760        dictionary.getMappings().put("TestRequest.Message", "Hello World!");761        reset(messageEndpoint, messageProducer);762        when(messageEndpoint.createProducer()).thenReturn(messageProducer);763        when(messageEndpoint.getActor()).thenReturn(null);764        doAnswer(invocation -> {765            Message message = (Message) invocation.getArguments()[0];766            Assert.assertEquals(StringUtils.trimAllWhitespace(message.getPayload(String.class)),767                    "{\"TestRequest\":{\"Message\":\"HelloWorld!\"}}");768            return null;769        }).when(messageProducer).send(any(Message.class), any(TestContext.class));770        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContext, context) {771            @Override772            public void execute() {773                send(builder -> builder.endpoint(messageEndpoint)774                        .messageType(MessageType.JSON)775                        .payload("{ \"TestRequest\": { \"Message\": \"?\" }}")776                        .dictionary(dictionary));777            }778        };779        final TestCase test = builder.getTestCase();780        Assert.assertEquals(test.getActionCount(), 1);781        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);782        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));783        Assert.assertEquals(action.getName(), "send");784        Assert.assertEquals(action.getEndpoint(), messageEndpoint);785        Assert.assertEquals(action.getDataDictionary(), dictionary);786    }787    @Test788    public void testSendBuilderWithDictionaryName() {789        final JsonMappingDataDictionary dictionary = new JsonMappingDataDictionary();790        dictionary.getMappings().put("TestRequest.Message", "Hello World!");791        reset(applicationContextMock, messageEndpoint, messageProducer);792        when(messageEndpoint.createProducer()).thenReturn(messageProducer);793        when(messageEndpoint.getActor()).thenReturn(null);794        doAnswer(invocation -> {795            Message message = (Message) invocation.getArguments()[0];796            Assert.assertEquals(StringUtils.trimAllWhitespace(message.getPayload(String.class)),797                    "{\"TestRequest\":{\"Message\":\"HelloWorld!\"}}");798            return null;799        }).when(messageProducer).send(any(Message.class), any(TestContext.class));800        when(applicationContextMock.getBean(TestContext.class)).thenReturn(applicationContext.getBean(TestContext.class));801        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());802        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());803        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());804        when(applicationContextMock.getBean("customDictionary", DataDictionary.class)).thenReturn(dictionary);805        final MockTestRunner builder = new MockTestRunner(getClass().getSimpleName(), applicationContextMock, context) {806            @Override807            public void execute() {808                send(builder -> builder.endpoint(messageEndpoint)809                        .messageType(MessageType.JSON)810                        .payload("{ \"TestRequest\": { \"Message\": \"?\" }}")811                        .dictionary("customDictionary"));812            }813        };814        final TestCase test = builder.getTestCase();815        Assert.assertEquals(test.getActionCount(), 1);816        Assert.assertEquals(test.getActions().get(0).getClass(), SendMessageAction.class);817        final SendMessageAction action = ((SendMessageAction)test.getActions().get(0));818        Assert.assertEquals(action.getName(), "send");819        Assert.assertEquals(action.getEndpoint(), messageEndpoint);820        Assert.assertEquals(action.getDataDictionary(), dictionary);821    }822}...

Source:SendMessageTestDesignerTest.java

...14 * limitations under the License.15 */16package com.consol.citrus.dsl.design;17import com.consol.citrus.TestCase;18import com.consol.citrus.actions.SendMessageAction;19import com.consol.citrus.container.SequenceAfterTest;20import com.consol.citrus.container.SequenceBeforeTest;21import com.consol.citrus.context.TestContext;22import com.consol.citrus.dsl.TestRequest;23import com.consol.citrus.dsl.actions.DelegatingTestAction;24import com.consol.citrus.endpoint.Endpoint;25import com.consol.citrus.message.DefaultMessage;26import com.consol.citrus.message.Message;27import com.consol.citrus.message.MessageHeaders;28import com.consol.citrus.message.MessageType;29import com.consol.citrus.report.TestActionListeners;30import com.consol.citrus.testng.AbstractTestNGUnitTest;31import com.consol.citrus.validation.builder.AbstractMessageContentBuilder;32import com.consol.citrus.validation.builder.PayloadTemplateMessageBuilder;33import com.consol.citrus.validation.builder.StaticMessageContentBuilder;34import com.consol.citrus.validation.json.JsonPathMessageConstructionInterceptor;35import com.consol.citrus.validation.json.JsonPathVariableExtractor;36import com.consol.citrus.validation.xml.XpathMessageConstructionInterceptor;37import com.consol.citrus.validation.xml.XpathPayloadVariableExtractor;38import com.consol.citrus.variable.MessageHeaderVariableExtractor;39import com.consol.citrus.variable.dictionary.DataDictionary;40import com.consol.citrus.variable.dictionary.xml.NodeMappingDataDictionary;41import org.mockito.Mockito;42import org.springframework.context.ApplicationContext;43import org.springframework.core.io.Resource;44import org.springframework.oxm.Marshaller;45import org.springframework.oxm.xstream.XStreamMarshaller;46import org.testng.Assert;47import org.testng.annotations.BeforeClass;48import org.testng.annotations.Test;49import java.io.ByteArrayInputStream;50import java.io.IOException;51import java.util.Collections;52import java.util.HashMap;53import static org.mockito.Mockito.reset;54import static org.mockito.Mockito.when;55/**56 * @author Christoph Deppisch57 */58public class SendMessageTestDesignerTest extends AbstractTestNGUnitTest {59    60    private Endpoint messageEndpoint = Mockito.mock(Endpoint.class);61    private ApplicationContext applicationContextMock = Mockito.mock(ApplicationContext.class);62    private Resource resource = Mockito.mock(Resource.class);63    private XStreamMarshaller marshaller = new XStreamMarshaller();64    @BeforeClass65    public void prepareMarshaller() {66        marshaller.getXStream().processAnnotations(TestRequest.class);67    }68    @Test69    public void testSendBuilderWithMessageInstance() {70        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {71            @Override72            public void configure() {73                send(messageEndpoint)74                    .message(new DefaultMessage("Foo").setHeader("operation", "foo"))75                        .header("additional", "additionalValue");76            }77        };78        builder.configure();79        final TestCase test = builder.getTestCase();80        Assert.assertEquals(test.getActionCount(), 1);81        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);82        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);83        84        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();85        Assert.assertEquals(action.getName(), "send");86        87        Assert.assertEquals(action.getEndpoint(), messageEndpoint);88        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);89        90        final StaticMessageContentBuilder messageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();91        Assert.assertEquals(messageBuilder.getMessage().getPayload(String.class), "Foo");92        Assert.assertEquals(messageBuilder.getMessage().getHeader("operation"), "foo");93        Assert.assertEquals(messageBuilder.getMessageHeaders().get("additional"), "additionalValue");94    }95    @Test96    public void testSendBuilderWithObjectMessageInstance() {97        final Message message = new DefaultMessage(10).setHeader("operation", "foo");98        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {99            @Override100            public void configure() {101                send(messageEndpoint)102                    .message(message);103            }104        };105        builder.configure();106        final TestCase test = builder.getTestCase();107        Assert.assertEquals(test.getActionCount(), 1);108        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);109        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);110        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();111        Assert.assertEquals(action.getName(), "send");112        Assert.assertEquals(action.getEndpoint(), messageEndpoint);113        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);114        final StaticMessageContentBuilder messageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();115        Assert.assertEquals(messageBuilder.getMessage().getPayload(), 10);116        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);117        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), message.getHeaders().size());118        Assert.assertEquals(messageBuilder.getMessage().getHeader(MessageHeaders.ID), message.getHeader(MessageHeaders.ID));119        Assert.assertEquals(messageBuilder.getMessage().getHeader("operation"), "foo");120        final Message constructed = messageBuilder.buildMessageContent(new TestContext(), MessageType.PLAINTEXT.name());121        Assert.assertEquals(constructed.getHeaders().size(), message.getHeaders().size() + 1);122        Assert.assertEquals(constructed.getHeader("operation"), "foo");123        Assert.assertEquals(constructed.getHeader(MessageHeaders.MESSAGE_TYPE), MessageType.PLAINTEXT.name());124        Assert.assertNotEquals(constructed.getHeader(MessageHeaders.ID), message.getHeader(MessageHeaders.ID));125    }126    @Test127    public void testSendBuilderWithObjectMessageInstanceAdditionalHeader() {128        final Message message = new DefaultMessage(10).setHeader("operation", "foo");129        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {130            @Override131            public void configure() {132                send(messageEndpoint)133                    .message(message)134                    .header("additional", "new");135            }136        };137        builder.configure();138        final TestCase test = builder.getTestCase();139        Assert.assertEquals(test.getActionCount(), 1);140        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);141        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);142        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();143        Assert.assertEquals(action.getName(), "send");144        Assert.assertEquals(action.getEndpoint(), messageEndpoint);145        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);146        final StaticMessageContentBuilder messageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();147        Assert.assertEquals(messageBuilder.getMessage().getPayload(), 10);148        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 1L);149        Assert.assertEquals(messageBuilder.getMessageHeaders().get("additional"), "new");150        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), message.getHeaders().size());151        Assert.assertEquals(messageBuilder.getMessage().getHeader(MessageHeaders.ID), message.getHeader(MessageHeaders.ID));152        Assert.assertEquals(messageBuilder.getMessage().getHeader("operation"), "foo");153        final Message constructed = messageBuilder.buildMessageContent(new TestContext(), MessageType.PLAINTEXT.name());154        Assert.assertEquals(constructed.getHeaders().size(), message.getHeaders().size() + 2);155        Assert.assertEquals(constructed.getHeader("operation"), "foo");156        Assert.assertEquals(constructed.getHeader("additional"), "new");157        Assert.assertEquals(constructed.getHeader(MessageHeaders.MESSAGE_TYPE), MessageType.PLAINTEXT.name());158    }159    @Test160    public void testSendBuilderWithPayloadModel() {161        reset(applicationContextMock);162        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());163        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());164        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());165        when(applicationContextMock.getBeansOfType(Marshaller.class)).thenReturn(Collections.singletonMap("marshaller", marshaller));166        when(applicationContextMock.getBean(Marshaller.class)).thenReturn(marshaller);167        final MockTestDesigner builder = new MockTestDesigner(applicationContextMock, context) {168            @Override169            public void configure() {170                send(messageEndpoint)171                        .payloadModel(new TestRequest("Hello Citrus!"));172            }173        };174        builder.configure();175        final TestCase test = builder.getTestCase();176        Assert.assertEquals(test.getActionCount(), 1);177        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);178        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);179        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();180        Assert.assertEquals(action.getName(), "send");181        Assert.assertEquals(action.getEndpoint(), messageEndpoint);182        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);183        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();184        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");185        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);186    }187    @Test188    public void testSendBuilderWithPayloadModelExplicitMarshaller() {189        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {190            @Override191            public void configure() {192                send(messageEndpoint)193                    .payload(new TestRequest("Hello Citrus!"), marshaller);194            }195        };196        builder.configure();197        final TestCase test = builder.getTestCase();198        Assert.assertEquals(test.getActionCount(), 1);199        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);200        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);201        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();202        Assert.assertEquals(action.getName(), "send");203        Assert.assertEquals(action.getEndpoint(), messageEndpoint);204        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);205        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();206        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");207        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);208    }209    @Test210    public void testSendBuilderWithPayloadModelExplicitMarshallerName() {211        reset(applicationContextMock);212        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());213        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());214        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());215        when(applicationContextMock.containsBean("myMarshaller")).thenReturn(true);216        when(applicationContextMock.getBean("myMarshaller")).thenReturn(marshaller);217        final MockTestDesigner builder = new MockTestDesigner(applicationContextMock, context) {218            @Override219            public void configure() {220                send(messageEndpoint)221                        .payload(new TestRequest("Hello Citrus!"), "myMarshaller");222            }223        };224        builder.configure();225        final TestCase test = builder.getTestCase();226        Assert.assertEquals(test.getActionCount(), 1);227        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);228        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);229        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();230        Assert.assertEquals(action.getName(), "send");231        Assert.assertEquals(action.getEndpoint(), messageEndpoint);232        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);233        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();234        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello Citrus!</Message></TestRequest>");235        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);236    }237    238    @Test239    public void testSendBuilderWithPayloadData() {240        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {241            @Override242            public void configure() {243                send(messageEndpoint)244                    .payload("<TestRequest><Message>Hello World!</Message></TestRequest>");245            }246        };247        builder.configure();248        final TestCase test = builder.getTestCase();249        Assert.assertEquals(test.getActionCount(), 1);250        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);251        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);252        253        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();254        Assert.assertEquals(action.getName(), "send");255        256        Assert.assertEquals(action.getEndpoint(), messageEndpoint);257        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);258        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();259        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");260        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);261    }262    @Test263    public void testSendBuilderWithPayloadResource() throws IOException {264        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {265            @Override266            public void configure() {267                send(messageEndpoint)268                    .payload(resource);269            }270        };271        272        reset(resource);273        when(resource.getInputStream()).thenReturn(new ByteArrayInputStream("somePayloadData".getBytes()));274        builder.configure();275        final TestCase test = builder.getTestCase();276        Assert.assertEquals(test.getActionCount(), 1);277        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);278        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);279        280        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();281        Assert.assertEquals(action.getName(), "send");282        283        Assert.assertEquals(action.getEndpoint(), messageEndpoint);284        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);285        286        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();287        Assert.assertEquals(messageBuilder.getPayloadData(), "somePayloadData");288        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);289    }290    291    @Test292    public void testSendBuilderWithEndpointName() {293        reset(applicationContextMock);294        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());295        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());296        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());297        final MockTestDesigner builder = new MockTestDesigner(applicationContextMock, context) {298            @Override299            public void configure() {300                send("fooMessageEndpoint")301                    .payload("<TestRequest><Message>Hello World!</Message></TestRequest>");302            }303        };304        builder.configure();305        final TestCase test = builder.getTestCase();306        Assert.assertEquals(test.getActionCount(), 1);307        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);308        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);309        310        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();311        Assert.assertEquals(action.getName(), "send");312        Assert.assertEquals(action.getEndpointUri(), "fooMessageEndpoint");313    }314    315    @Test316    public void testSendBuilderWithHeaders() {317        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {318            @Override319            public void configure() {320                send(messageEndpoint)321                    .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")322                    .headers(Collections.singletonMap("some", "value"))323                    .header("operation", "foo")324                    .header("language", "eng");325            }326        };327        builder.configure();328        final TestCase test = builder.getTestCase();329        Assert.assertEquals(test.getActionCount(), 1);330        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);331        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);332        333        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();334        Assert.assertEquals(action.getName(), "send");335        336        Assert.assertEquals(action.getEndpoint(), messageEndpoint);337        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);338        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();339        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");340        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 3L);341        Assert.assertEquals(messageBuilder.getMessageHeaders().get("some"), "value");342        Assert.assertEquals(messageBuilder.getMessageHeaders().get("operation"), "foo");343        Assert.assertEquals(messageBuilder.getMessageHeaders().get("language"), "eng");344    }345    346    @Test347    public void testSendBuilderWithHeaderData() {348        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {349            @Override350            public void configure() {351                send(messageEndpoint)352                    .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")353                    .header("<Header><Name>operation</Name><Value>foo</Value></Header>");354                355                send(messageEndpoint)356                    .message(new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>"))357                    .header("<Header><Name>operation</Name><Value>foo</Value></Header>");358            }359        };360        builder.configure();361        final TestCase test = builder.getTestCase();362        Assert.assertEquals(test.getActionCount(), 2);363        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);364        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);365        Assert.assertEquals(test.getActions().get(1).getClass(), DelegatingTestAction.class);366        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(1)).getDelegate().getClass(), SendMessageAction.class);367        368        SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();369        Assert.assertEquals(action.getName(), "send");370        371        Assert.assertEquals(action.getEndpoint(), messageEndpoint);372        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);373        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();374        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");375        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);376        Assert.assertEquals(messageBuilder.getHeaderData().size(), 1L);377        Assert.assertEquals(messageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo</Value></Header>");378        Assert.assertEquals(messageBuilder.getHeaderResources().size(), 0L);379        action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(1)).getDelegate();380        Assert.assertEquals(action.getName(), "send");381        Assert.assertEquals(action.getEndpoint(), messageEndpoint);382        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);383        final StaticMessageContentBuilder staticMessageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();384        Assert.assertEquals(staticMessageBuilder.getMessage().getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");385        Assert.assertEquals(staticMessageBuilder.getMessageHeaders().size(), 0L);386        Assert.assertEquals(staticMessageBuilder.getHeaderData().size(), 1L);387        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo</Value></Header>");388        Assert.assertEquals(staticMessageBuilder.getHeaderResources().size(), 0L);389    }390    @Test391    public void testSendBuilderWithMultipleHeaderData() {392        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {393            @Override394            public void configure() {395                send(messageEndpoint)396                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")397                        .header("<Header><Name>operation</Name><Value>foo1</Value></Header>")398                        .header("<Header><Name>operation</Name><Value>foo2</Value></Header>");399                send(messageEndpoint)400                        .message(new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>"))401                        .header("<Header><Name>operation</Name><Value>foo1</Value></Header>")402                        .header("<Header><Name>operation</Name><Value>foo2</Value></Header>");403            }404        };405        builder.configure();406        final TestCase test = builder.getTestCase();407        Assert.assertEquals(test.getActionCount(), 2);408        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);409        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);410        Assert.assertEquals(test.getActions().get(1).getClass(), DelegatingTestAction.class);411        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(1)).getDelegate().getClass(), SendMessageAction.class);412        SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();413        Assert.assertEquals(action.getName(), "send");414        Assert.assertEquals(action.getEndpoint(), messageEndpoint);415        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);416        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();417        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");418        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);419        Assert.assertEquals(messageBuilder.getHeaderData().size(), 2L);420        Assert.assertEquals(messageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo1</Value></Header>");421        Assert.assertEquals(messageBuilder.getHeaderData().get(1), "<Header><Name>operation</Name><Value>foo2</Value></Header>");422        Assert.assertEquals(messageBuilder.getHeaderResources().size(), 0L);423        action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(1)).getDelegate();424        Assert.assertEquals(action.getName(), "send");425        Assert.assertEquals(action.getEndpoint(), messageEndpoint);426        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);427        final StaticMessageContentBuilder staticMessageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();428        Assert.assertEquals(staticMessageBuilder.getMessage().getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");429        Assert.assertEquals(staticMessageBuilder.getMessageHeaders().size(), 0L);430        Assert.assertEquals(staticMessageBuilder.getHeaderData().size(), 2L);431        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(0), "<Header><Name>operation</Name><Value>foo1</Value></Header>");432        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(1), "<Header><Name>operation</Name><Value>foo2</Value></Header>");433        Assert.assertEquals(staticMessageBuilder.getHeaderResources().size(), 0L);434    }435    436    @Test437    public void testSendBuilderWithHeaderDataResource() throws IOException {438        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {439            @Override440            public void configure() {441                send(messageEndpoint)442                    .payload("<TestRequest><Message>Hello World!</Message></TestRequest>")443                    .header(resource);444                445                send(messageEndpoint)446                    .message(new DefaultMessage("<TestRequest><Message>Hello World!</Message></TestRequest>"))447                    .header(resource);448            }449        };450        451        reset(resource);452        when(resource.getInputStream()).thenReturn(new ByteArrayInputStream("someHeaderData".getBytes()))453                                       .thenReturn(new ByteArrayInputStream("otherHeaderData".getBytes()));454        builder.configure();455        final TestCase test = builder.getTestCase();456        Assert.assertEquals(test.getActionCount(), 2);457        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);458        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);459        Assert.assertEquals(test.getActions().get(1).getClass(), DelegatingTestAction.class);460        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(1)).getDelegate().getClass(), SendMessageAction.class);461        462        SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();463        Assert.assertEquals(action.getName(), "send");464        465        Assert.assertEquals(action.getEndpoint(), messageEndpoint);466        Assert.assertEquals(action.getMessageBuilder().getClass(), PayloadTemplateMessageBuilder.class);467        final PayloadTemplateMessageBuilder messageBuilder = (PayloadTemplateMessageBuilder) action.getMessageBuilder();468        Assert.assertEquals(messageBuilder.getPayloadData(), "<TestRequest><Message>Hello World!</Message></TestRequest>");469        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 0L);470        Assert.assertEquals(messageBuilder.getHeaderData().size(), 1L);471        Assert.assertEquals(messageBuilder.getHeaderData().get(0), "someHeaderData");472        Assert.assertEquals(messageBuilder.getHeaderResources().size(), 0L);473        action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(1)).getDelegate();474        Assert.assertEquals(action.getName(), "send");475        Assert.assertEquals(action.getEndpoint(), messageEndpoint);476        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);477        final StaticMessageContentBuilder staticMessageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();478        Assert.assertEquals(staticMessageBuilder.getMessage().getPayload(String.class), "<TestRequest><Message>Hello World!</Message></TestRequest>");479        Assert.assertEquals(staticMessageBuilder.getMessageHeaders().size(), 0L);480        Assert.assertEquals(staticMessageBuilder.getHeaderData().size(), 1L);481        Assert.assertEquals(staticMessageBuilder.getHeaderData().get(0), "otherHeaderData");482        Assert.assertEquals(staticMessageBuilder.getHeaderResources().size(), 0L);483    }484    485    @Test486    public void testSendBuilderExtractFromPayload() {487        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {488            @Override489            public void configure() {490                send(messageEndpoint)491                    .payload("<TestRequest><Message lang=\"ENG\">Hello World!</Message></TestRequest>")492                    .extractFromPayload("/TestRequest/Message", "text")493                    .extractFromPayload("/TestRequest/Message/@lang", "language");494            }495        };496        builder.configure();497        final TestCase test = builder.getTestCase();498        Assert.assertEquals(test.getActionCount(), 1);499        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);500        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);501        502        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();503        Assert.assertEquals(action.getName(), "send");504        505        Assert.assertEquals(action.getEndpoint(), messageEndpoint);506        507        Assert.assertEquals(action.getVariableExtractors().size(), 1);508        Assert.assertTrue(action.getVariableExtractors().get(0) instanceof XpathPayloadVariableExtractor);509        Assert.assertTrue(((XpathPayloadVariableExtractor)action.getVariableExtractors().get(0)).getXpathExpressions().containsKey("/TestRequest/Message"));510        Assert.assertTrue(((XpathPayloadVariableExtractor)action.getVariableExtractors().get(0)).getXpathExpressions().containsKey("/TestRequest/Message/@lang"));511    }512    @Test513    public void testSendBuilderExtractJsonPathFromPayload() {514        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {515            @Override516            public void configure() {517                send(messageEndpoint)518                        .messageType(MessageType.JSON)519                        .payload("{\"text\":\"Hello World!\", \"person\":{\"name\":\"John\",\"surname\":\"Doe\"}, \"index\":5, \"id\":\"x123456789x\"}")520                        .extractFromPayload("$.text", "text")521                        .extractFromPayload("$.person", "language");522            }523        };524        builder.configure();525        final TestCase test = builder.getTestCase();526        Assert.assertEquals(test.getActionCount(), 1);527        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);528        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);529        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();530        Assert.assertEquals(action.getName(), "send");531        Assert.assertEquals(action.getEndpoint(), messageEndpoint);532        Assert.assertEquals(action.getVariableExtractors().size(), 1);533        Assert.assertTrue(action.getVariableExtractors().get(0) instanceof JsonPathVariableExtractor);534        Assert.assertTrue(((JsonPathVariableExtractor)action.getVariableExtractors().get(0)).getJsonPathExpressions().containsKey("$.text"));535        Assert.assertTrue(((JsonPathVariableExtractor)action.getVariableExtractors().get(0)).getJsonPathExpressions().containsKey("$.person"));536    }537    538    @Test539    public void testSendBuilderExtractFromHeader() {540        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {541            @Override542            public void configure() {543                send(messageEndpoint)544                    .payload("<TestRequest><Message lang=\"ENG\">Hello World!</Message></TestRequest>")545                    .extractFromHeader("operation", "ops")546                    .extractFromHeader("requestId", "id");547            }548        };549        builder.configure();550        final TestCase test = builder.getTestCase();551        Assert.assertEquals(test.getActionCount(), 1);552        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);553        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);554        555        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();556        Assert.assertEquals(action.getName(), "send");557        558        Assert.assertEquals(action.getEndpoint(), messageEndpoint);559        560        Assert.assertEquals(action.getVariableExtractors().size(), 1);561        Assert.assertTrue(action.getVariableExtractors().get(0) instanceof MessageHeaderVariableExtractor);562        Assert.assertTrue(((MessageHeaderVariableExtractor)action.getVariableExtractors().get(0)).getHeaderMappings().containsKey("operation"));563        Assert.assertTrue(((MessageHeaderVariableExtractor)action.getVariableExtractors().get(0)).getHeaderMappings().containsKey("requestId"));564    }565    @Test566    public void testXpathSupport() {567        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {568            @Override569            public void configure() {570                send(messageEndpoint)571                        .payload("<TestRequest><Message lang=\"ENG\">Hello World!</Message></TestRequest>")572                        .xpath("/TestRequest/Message", "Hello World!");573            }574        };575        builder.configure();576        final TestCase test = builder.getTestCase();577        Assert.assertEquals(test.getActionCount(), 1);578        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);579        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);580        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();581        Assert.assertEquals(action.getName(), "send");582        Assert.assertEquals(action.getEndpoint(), messageEndpoint);583        Assert.assertTrue(action.getMessageBuilder() instanceof AbstractMessageContentBuilder);584        Assert.assertEquals(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().size(), 1);585        Assert.assertTrue(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0) instanceof XpathMessageConstructionInterceptor);586        Assert.assertEquals(((XpathMessageConstructionInterceptor)((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0)).getXPathExpressions().get("/TestRequest/Message"), "Hello World!");587    }588    @Test589    public void testJsonPathSupport() {590        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {591            @Override592            public void configure() {593                send(messageEndpoint)594                        .payload("{ \"TestRequest\": { \"Message\": \"?\" }}")595                        .jsonPath("$.TestRequest.Message", "Hello World!");596            }597        };598        builder.configure();599        final TestCase test = builder.getTestCase();600        Assert.assertEquals(test.getActionCount(), 1);601        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);602        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);603        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();604        Assert.assertEquals(action.getName(), "send");605        Assert.assertEquals(action.getEndpoint(), messageEndpoint);606        Assert.assertTrue(action.getMessageBuilder() instanceof AbstractMessageContentBuilder);607        Assert.assertEquals(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().size(), 1);608        Assert.assertTrue(((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0) instanceof JsonPathMessageConstructionInterceptor);609        Assert.assertEquals(((JsonPathMessageConstructionInterceptor)((AbstractMessageContentBuilder) action.getMessageBuilder()).getMessageInterceptors().get(0)).getJsonPathExpressions().get("$.TestRequest.Message"), "Hello World!");610    }611    @Test612    public void testSendBuilderWithDictionary() {613        final DataDictionary dictionary = new NodeMappingDataDictionary();614        reset(applicationContextMock);615        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());616        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());617        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());618        final MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {619            @Override620            public void configure() {621                send(messageEndpoint)622                        .payload("{ \"TestRequest\": { \"Message\": \"?\" }}")623                        .dictionary(dictionary);624            }625        };626        builder.configure();627        final TestCase test = builder.getTestCase();628        Assert.assertEquals(test.getActionCount(), 1);629        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);630        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);631        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();632        Assert.assertEquals(action.getName(), "send");633        Assert.assertEquals(action.getEndpoint(), messageEndpoint);634        Assert.assertEquals(action.getDataDictionary(), dictionary);635    }636    @Test637    public void testSendBuilderWithDictionaryName() {638        final DataDictionary dictionary = new NodeMappingDataDictionary();639        reset(applicationContextMock);640        when(applicationContextMock.getBean("customDictionary", DataDictionary.class)).thenReturn(dictionary);641        when(applicationContextMock.getBean(TestActionListeners.class)).thenReturn(new TestActionListeners());642        when(applicationContextMock.getBeansOfType(SequenceBeforeTest.class)).thenReturn(new HashMap<>());643        when(applicationContextMock.getBeansOfType(SequenceAfterTest.class)).thenReturn(new HashMap<>());644        final MockTestDesigner builder = new MockTestDesigner(applicationContextMock, context) {645            @Override646            public void configure() {647                send(messageEndpoint)648                        .payload("TestMessage")649                        .header("operation", "sayHello")650                        .dictionary("customDictionary");651            }652        };653        builder.configure();654        final TestCase test = builder.getTestCase();655        Assert.assertEquals(test.getActionCount(), 1);656        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);657        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);658        final SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();659        Assert.assertEquals(action.getName(), "send");660        Assert.assertEquals(action.getEndpoint(), messageEndpoint);661        Assert.assertEquals(action.getDataDictionary(), dictionary);662    }663}...

Source:SendHttpMessageTestDesignerTest.java

...14 * limitations under the License.15 */16package com.consol.citrus.dsl.design;17import com.consol.citrus.TestCase;18import com.consol.citrus.actions.SendMessageAction;19import com.consol.citrus.dsl.actions.DelegatingTestAction;20import com.consol.citrus.endpoint.resolver.DynamicEndpointUriResolver;21import com.consol.citrus.http.client.HttpClient;22import com.consol.citrus.http.message.HttpMessageContentBuilder;23import com.consol.citrus.http.message.HttpMessageHeaders;24import com.consol.citrus.message.DefaultMessage;25import com.consol.citrus.testng.AbstractTestNGUnitTest;26import com.consol.citrus.validation.builder.StaticMessageContentBuilder;27import org.mockito.Mockito;28import org.springframework.context.ApplicationContext;29import org.springframework.http.HttpMethod;30import org.testng.Assert;31import org.testng.annotations.Test;32/**33 * @author Christoph Deppisch34 */35public class SendHttpMessageTestDesignerTest extends AbstractTestNGUnitTest {36    private HttpClient httpClient = Mockito.mock(HttpClient.class);37    private ApplicationContext applicationContextMock = Mockito.mock(ApplicationContext.class);38    @Test39    public void testFork() {40        MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {41            @Override42            public void configure() {43                send(httpClient)44                        .message(new DefaultMessage("Foo").setHeader("operation", "foo"))45                            .header("additional", "additionalValue");46                send(httpClient)47                        .message(new DefaultMessage("Foo").setHeader("operation", "foo"))48                        .fork(true);49            }50        };51        builder.configure();52        TestCase test = builder.getTestCase();53        Assert.assertEquals(test.getActionCount(), 2);54        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);55        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);56        Assert.assertEquals(test.getActions().get(1).getClass(), DelegatingTestAction.class);57        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(1)).getDelegate().getClass(), SendMessageAction.class);58        SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();59        Assert.assertEquals(action.getName(), "send");60        Assert.assertEquals(action.getEndpoint(), httpClient);61        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);62        StaticMessageContentBuilder messageBuilder = (StaticMessageContentBuilder) action.getMessageBuilder();63        Assert.assertEquals(messageBuilder.getMessage().getPayload(String.class), "Foo");64        Assert.assertEquals(messageBuilder.getMessage().getHeader("operation"), "foo");65        Assert.assertEquals(messageBuilder.getMessageHeaders().size(), 1L);66        Assert.assertEquals(messageBuilder.getMessageHeaders().get("additional"), "additionalValue");67        Assert.assertFalse(action.isForkMode());68        action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(1)).getDelegate();69        Assert.assertEquals(action.getName(), "send");70        Assert.assertEquals(action.getEndpoint(), httpClient);71        Assert.assertEquals(action.getMessageBuilder().getClass(), StaticMessageContentBuilder.class);72        Assert.assertTrue(action.isForkMode());73    }74    @Test75    public void testHttpMethod() {76        MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {77            @Override78            public void configure() {79                http().client(httpClient)80                        .send()81                        .get()82                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>");83            }84        };85        builder.configure();86        TestCase test = builder.getTestCase();87        Assert.assertEquals(test.getActionCount(), 1);88        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);89        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);90        SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();91        Assert.assertEquals(action.getName(), "send");92        Assert.assertEquals(action.getEndpoint(), httpClient);93        Assert.assertEquals(action.getMessageBuilder().getClass(), HttpMessageContentBuilder.class);94        HttpMessageContentBuilder messageBuilder = (HttpMessageContentBuilder) action.getMessageBuilder();95        Assert.assertEquals(messageBuilder.getMessage().getPayload(), "<TestRequest><Message>Hello World!</Message></TestRequest>");96        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), 3L);97        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_REQUEST_METHOD), HttpMethod.GET.name());98    }99    @Test100    public void testHttpRequestUriAndPath() {101        MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {102            @Override103            public void configure() {104                http().client(httpClient)105                        .send()106                        .get("/test")107                        .uri("http://localhost:8080/")108                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>");109            }110        };111        builder.configure();112        TestCase test = builder.getTestCase();113        Assert.assertEquals(test.getActionCount(), 1);114        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);115        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);116        SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();117        Assert.assertEquals(action.getName(), "send");118        Assert.assertEquals(action.getEndpoint(), httpClient);119        Assert.assertEquals(action.getMessageBuilder().getClass(), HttpMessageContentBuilder.class);120        HttpMessageContentBuilder messageBuilder = (HttpMessageContentBuilder) action.getMessageBuilder();121        Assert.assertEquals(messageBuilder.getMessage().getPayload(), "<TestRequest><Message>Hello World!</Message></TestRequest>");122        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), 6L);123        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_REQUEST_URI), "http://localhost:8080/");124        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(DynamicEndpointUriResolver.ENDPOINT_URI_HEADER_NAME), "http://localhost:8080/");125        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(DynamicEndpointUriResolver.REQUEST_PATH_HEADER_NAME), "/test");126    }127    @Test128    public void testHttpRequestUriAndQueryParams() {129        MockTestDesigner builder = new MockTestDesigner(applicationContext, context) {130            @Override131            public void configure() {132                http().client(httpClient)133                        .send()134                        .get()135                        .uri("http://localhost:8080/")136                        .queryParam("param1", "value1")137                        .queryParam("param2", "value2")138                        .payload("<TestRequest><Message>Hello World!</Message></TestRequest>");139            }140        };141        builder.configure();142        TestCase test = builder.getTestCase();143        Assert.assertEquals(test.getActionCount(), 1);144        Assert.assertEquals(test.getActions().get(0).getClass(), DelegatingTestAction.class);145        Assert.assertEquals(((DelegatingTestAction)test.getActions().get(0)).getDelegate().getClass(), SendMessageAction.class);146        SendMessageAction action = (SendMessageAction) ((DelegatingTestAction)test.getActions().get(0)).getDelegate();147        Assert.assertEquals(action.getName(), "send");148        Assert.assertEquals(action.getEndpoint(), httpClient);149        Assert.assertEquals(action.getMessageBuilder().getClass(), HttpMessageContentBuilder.class);150        HttpMessageContentBuilder messageBuilder = (HttpMessageContentBuilder) action.getMessageBuilder();151        Assert.assertEquals(messageBuilder.getMessage().getPayload(), "<TestRequest><Message>Hello World!</Message></TestRequest>");152        Assert.assertEquals(messageBuilder.getMessage().getHeaders().size(), 7L);153        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(HttpMessageHeaders.HTTP_REQUEST_URI), "http://localhost:8080/");154        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(DynamicEndpointUriResolver.ENDPOINT_URI_HEADER_NAME), "http://localhost:8080/");155        Assert.assertEquals(messageBuilder.getMessage().getHeaders().get(DynamicEndpointUriResolver.QUERY_PARAM_HEADER_NAME), "param1=value1,param2=value2");156    }157}...

SendMessageAction

Using AI Code Generation

1package com.consol.citrus.dsl.builder;2import com.consol.citrus.actions.SendMessageAction;3import com.consol.citrus.dsl.runner.TestRunner;4import com.consol.citrus.message.MessageType;5public class SendMessageActionBuilder extends AbstractTestActionBuilder<SendMessageAction> {6    public SendMessageActionBuilder(TestRunner testRunner, SendMessageAction action) {7        super(testRunner, action);8    }9    public SendMessageActionBuilder message(String payload) {10        action.setMessage(payload);11        return this;12    }13    public SendMessageActionBuilder message(byte[] payload) {14        action.setMessage(payload);15        return this;16    }17    public SendMessageActionBuilder message(Object payload) {18        action.setMessage(payload);19        return this;20    }21    public SendMessageActionBuilder message(Object payload, MessageType messageType) {22        action.setMessage(payload, messageType);23        return this;24    }25    public SendMessageActionBuilder messageName(String name) {26        action.setMessageName(name);27        return this;28    }29    public SendMessageActionBuilder endpoint(String uri) {30        action.setEndpointUri(uri);31        return this;32    }33    public SendMessageActionBuilder messageType(MessageType messageType) {34        action.setMessageType(messageType);35        return this;36    }37    public SendMessageActionBuilder headers(String headers) {38        action.setMessageHeaders(headers);39        return this;40    }

SendMessageAction

Using AI Code Generation

1package com.consol.citrus.dsl.design;2import com.consol.citrus.dsl.builder.SendMessageBuilder;3import com.consol.citrus.message.MessageType;4import com.consol.citrus.testng.AbstractTestNGCitrusTest;5import org.springframework.core.io.ClassPathResource;6import org.testng.annotations.Test;7public class SendMessageActionJavaITest extends AbstractTestNGCitrusTest {8    public void sendMessageActionJavaITest() {9        variable("messageId", "1234567890");10        variable("messageType", "TestMessage");11        variable("correlationId", "0987654321");12        variable("contentType", "text/xml");13        variable("data", "Hello Citrus!");14        parallel(15            sequential(16                send("sendMessageActionJavaITestClient")17                    .endpoint("sendMessageActionJavaITestEndpoint")18                    .payload("<TestMessage>" +19                    .header("operation", "greetMe")20                    .header("messageId", "${messageId}")21                    .header("messageType", "${messageType}")22                    .header("correlationId", "${correlationId}")23                    .header("contentType", "${contentType}")24                    .header("data", "${data}")25                    .header("endpointUri", "${endpointUri}")26            sequential(27                receive("sendMessageActionJavaITestClient")28                    .endpoint("sendMessageActionJavaITestEndpoint")29                    .payload("<TestMessage>" +30                    .header("operation", "greetMe")31                    .header("messageId", "${messageId}")32                    .header("messageType", "${messageType}")33                    .header("correlationId", "${correlationId}")34                    .header("contentType", "${contentType}")35                    .header("data", "${data}")36                    .header("endpointUri", "${endpointUri}")37        );38    }39}40package com.consol.citrus.dsl.design;41import com.consol.citrus.dsl.builder.SendMessageBuilder;42import com.consol.citrus.message.MessageType;43import com.consol.citrus.testng.AbstractTestNGCitrusTest;44import org.springframework.core.io

SendMessageAction

Using AI Code Generation

1package com.consol.citrus.dsl.design;2import com.consol.citrus.dsl.builder.SendMessageActionBuilder;3import com.consol.citrus.dsl.builder.SendSoapMessageActionBuilder;4import com.consol.citrus.dsl.builder.SendSoapMessageBuilder;5import com.consol.citrus.dsl.builder.SendSoapMessageBuilderSupport;6import com.consol.citrus.message.MessageType;7import com.consol.citrus.testng.AbstractTestNGCitrusTest;8import com.consol.citrus.ws.actions.SendMessageAction;9import org.springframework.http.HttpStatus;10import org.springframework.http.MediaType;11import org.testng.annotations.Test;12import static com.consol.citrus.actions.SendMessageAction.Builder.send;13import static com.consol.citrus.dsl.builder.SendMessageActionBuilder.send;14import static com.consol.citrus.dsl.builder.SendSoapMessageActionBuilder.soap;15import static com.consol.citrus.dsl.builder.SendSoapMessageBuilder.soap;16import static com.consol.citrus.dsl.builder.SendSoapMessageBuilderSupport.soap;17public class SendMessageActionTest extends AbstractTestNGCitrusTest {18    public void send() {19        send(sendMessageActionBuilder -> sendMessageActionBuilder.message("Hello World!"));20    }21    public void sendWithMessageName() {22        send(sendMessageActionBuilder -> sendMessageActionBuilder.messageName("HelloMessage"));23    }24    public void sendWithEndpoint() {25        send(sendMessageActionBuilder -> sendMessageActionBuilder.endpoint("helloEndpoint"));26    }27    public void sendWithEndpointName() {28        send(sendMessageActionBuilder -> sendMessageActionBuilder.endpointName("helloEndpoint"));29    }30    public void sendWithMessage() {31        send(sendMessageActionBuilder -> sendMessageActionBuilder.message("Hello World!"));32    }33    public void sendWithMessageBuilder() {34        send(sendMessageActionBuilder -> sendMessageActionBuilder.message(sendSoapMessageBuilder -> sendSoapMessageBuilder.soap().client("helloClient")));35    }36    public void sendWithMessageBuilderSupport() {37        send(sendMessageActionBuilder -> sendMessageActionBuilder.message(sendSoapMessageBuilderSupport -> sendSoapMessageBuilderSupport.soap().client("helloClient")));38    }39    public void sendWithMessageActionBuilder() {40        send(sendMessageActionBuilder -> sendMessageActionBuilder.message(sendSoapMessageActionBuilder -> sendSoapMessageActionBuilder.soap().client("hello

SendMessageAction

Using AI Code Generation

1package com.consol.citrus.dsl.design;2import com.consol.citrus.dsl.builder.SendMessageActionBuilder;3import com.consol.citrus.dsl.design.TestDesigner;4import com.consol.citrus.dsl.design.TestDesignerBeforeTestSupport;5import com.consol.citrus.message.MessageType;6import org.testng.annotations.Test;7public class SendMessageActionJavaITest extends TestDesignerBeforeTestSupport {8    public void sendMessageActionJavaITest() {9        variable("message", "Hello Citrus!");10        variable("contentType", "text/plain");11        variable("correlationId", "1234567890");12        variable("charset", "UTF-8");13        variable("headerName", "operation");14        variable("headerValue", "greet");15        variable("headerName2", "citrus:testCaseName");16        variable("headerValue2", "Citrus:Java:sendMessageAction");17        variable("headerName3", "citrus:testCaseName");18        variable("headerValue3", "Citrus:Java:sendMessageAction");19        variable("headerName4", "citrus:testCaseName");20        variable("headerValue4", "Citrus:Java:sendMessageAction");21        variable("headerName5", "citrus:testCaseName");22        variable("headerValue5", "Citrus:Java:sendMessageAction");23        variable("headerName6", "citrus:testCaseName");24        variable("headerValue6", "Citrus:Java:sendMessageAction");25        variable("headerName7", "citrus:testCaseName");26        variable("headerValue7", "Citrus:Java:sendMessageAction");27        variable("headerName8", "citrus:testCaseName");28        variable("headerValue8", "Citrus:Java:sendMessageAction");29        variable("headerName9", "citrus:testCaseName");30        variable("headerValue9", "Citrus:Java:sendMessageAction");31        variable("headerName10", "citrus:testCaseName");32        variable("headerValue10", "Citrus:Java:sendMessageAction");33        variable("headerName11", "citrus:testCaseName");34        variable("headerValue11", "Citrus:Java:sendMessageAction");35        variable("headerName12", "citrus:testCaseName");36        variable("headerValue12", "Citrus:Java:sendMessageAction");37        variable("headerName13", "citrus:testCase

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.