Advertisement
Guest User

Untitled

a guest
Aug 26th, 2015
129
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 2.88 KB | None | 0 0
  1. package de.intersales.qbus.joomlashop.itests;
  2.  
  3. import de.intersales.qbus.itest.paxexam.KarafConfigurationBuilder;
  4. import org.apache.activemq.camel.component.ActiveMQComponent;
  5. import org.apache.camel.Exchange;
  6. import org.apache.camel.Processor;
  7. import org.apache.camel.builder.RouteBuilder;
  8. import org.apache.camel.component.mock.MockEndpoint;
  9. import org.apache.camel.model.ModelCamelContext;
  10. import org.apache.camel.test.junit4.CamelTestSupport;
  11. import org.junit.Assert;
  12. import org.junit.Test;
  13. import org.junit.runner.RunWith;
  14. import org.ops4j.pax.exam.Configuration;
  15. import org.ops4j.pax.exam.Option;
  16. import org.ops4j.pax.exam.junit.PaxExam;
  17. import org.ops4j.pax.exam.karaf.options.KarafDistributionConfigurationFileReplacementOption;
  18. import org.slf4j.Logger;
  19. import org.slf4j.LoggerFactory;
  20.  
  21. import java.io.File;
  22.  
  23. /**
  24.  * Testing the
  25.  */
  26. @RunWith(PaxExam.class)
  27. public class JoomlashopTest extends CamelTestSupport {
  28.  
  29.     private static Logger LOG = LoggerFactory
  30.             .getLogger(JoomlashopTest.class);
  31.  
  32.  
  33.     @Configuration
  34.     public Option[] configure() {
  35.         return KarafConfigurationBuilder
  36.                 .withServiceMix()
  37.                 .addConfiguration("joomlashop.orders", "orders.file.path", "orders/")
  38.                 .installFeature("org.apache.camel.karaf", "apache-camel", "camel-test")
  39.                 .installFeature("de.intersales.qbus", "qbus-core-features", "xml-types")
  40.                 .installFeature("de.intersales.qbus", "joomlashop.features", "joomlashop.mediation.orders.file")
  41.                 .addOption(new KarafDistributionConfigurationFileReplacementOption("orders/order.xml", new File("src/test/resources/order.xml")))
  42.                 .build();
  43.     }
  44.  
  45.     @Test
  46.     public void test() throws Exception {
  47.  
  48.         context().addComponent("activemq", new ActiveMQComponent());
  49.  
  50.         MockEndpoint itestMock = getMockEndpoint("mock:itest");
  51.         itestMock.expectedMinimumMessageCount(1);
  52.         itestMock.whenAnyExchangeReceived(new Processor() {
  53.             @Override
  54.             public void process(Exchange exchange) throws Exception {
  55.                 System.out.println(exchange.getIn().getBody(String.class));
  56.             }
  57.         });
  58.  
  59.         template.start();
  60.  
  61.         Thread.sleep(20000);
  62.  
  63.         assertMockEndpointsSatisfied();
  64.  
  65.  
  66.     }
  67.  
  68.     @Override
  69.     protected RouteBuilder createRouteBuilder() {
  70.         return new RouteBuilder() {
  71.  
  72.             @Override
  73.             public ModelCamelContext getContext() {
  74.                 ModelCamelContext context = super.getContext();
  75.                 context.addComponent("activemq", new ActiveMQComponent());
  76.                 return context;
  77.             }
  78.  
  79.             @Override
  80.             public void configure() throws Exception {
  81.                 from("activemq:queue:qstep.order.sales")
  82.                         .to("mock:itest");
  83.             }
  84.         };
  85.     }
  86.  
  87. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement