Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package de.intersales.qbus.joomlashop.itests;
- import de.intersales.qbus.itest.paxexam.KarafConfigurationBuilder;
- import org.apache.activemq.camel.component.ActiveMQComponent;
- import org.apache.camel.Exchange;
- import org.apache.camel.Processor;
- import org.apache.camel.builder.RouteBuilder;
- import org.apache.camel.component.mock.MockEndpoint;
- import org.apache.camel.model.ModelCamelContext;
- import org.apache.camel.test.junit4.CamelTestSupport;
- import org.junit.Assert;
- import org.junit.Test;
- import org.junit.runner.RunWith;
- import org.ops4j.pax.exam.Configuration;
- import org.ops4j.pax.exam.Option;
- import org.ops4j.pax.exam.junit.PaxExam;
- import org.ops4j.pax.exam.karaf.options.KarafDistributionConfigurationFileReplacementOption;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import java.io.File;
- /**
- * Testing the
- */
- @RunWith(PaxExam.class)
- public class JoomlashopTest extends CamelTestSupport {
- private static Logger LOG = LoggerFactory
- .getLogger(JoomlashopTest.class);
- @Configuration
- public Option[] configure() {
- return KarafConfigurationBuilder
- .withServiceMix()
- .addConfiguration("joomlashop.orders", "orders.file.path", "orders/")
- .installFeature("org.apache.camel.karaf", "apache-camel", "camel-test")
- .installFeature("de.intersales.qbus", "qbus-core-features", "xml-types")
- .installFeature("de.intersales.qbus", "joomlashop.features", "joomlashop.mediation.orders.file")
- .addOption(new KarafDistributionConfigurationFileReplacementOption("orders/order.xml", new File("src/test/resources/order.xml")))
- .build();
- }
- @Test
- public void test() throws Exception {
- context().addComponent("activemq", new ActiveMQComponent());
- MockEndpoint itestMock = getMockEndpoint("mock:itest");
- itestMock.expectedMinimumMessageCount(1);
- itestMock.whenAnyExchangeReceived(new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- System.out.println(exchange.getIn().getBody(String.class));
- }
- });
- template.start();
- Thread.sleep(20000);
- assertMockEndpointsSatisfied();
- }
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public ModelCamelContext getContext() {
- ModelCamelContext context = super.getContext();
- context.addComponent("activemq", new ActiveMQComponent());
- return context;
- }
- @Override
- public void configure() throws Exception {
- from("activemq:queue:qstep.order.sales")
- .to("mock:itest");
- }
- };
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement