svn commit: r1518366 - /activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/AMQ2240Test.java

[ta...@apache.org]

Author: tabish
Date: Wed Aug 28 20:27:13 2013
New Revision: 1518366

URL: http://svn.apache.org/r1518366
Log:
Fix failing test case, things are more lazily loaded now so we must actually invoke the route before the URI will get used and the exception fired. 

Modified:
    activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/AMQ2240Test.java

Modified: activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/AMQ2240Test.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/AMQ2240Test.java?rev=1518366&r1=1518365&r2=1518366&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/AMQ2240Test.java (original)
+++ activemq/trunk/activemq-camel/src/test/java/org/apache/activemq/camel/AMQ2240Test.java Wed Aug 28 20:27:13 2013
@@ -16,15 +16,15 @@
  */
 package org.apache.activemq.camel;
 
-import static org.junit.Assert.*;
+import static org.junit.Assert.fail;
 
-import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.camel.AMQ2611Test.Consumer;
 import org.apache.activemq.camel.component.ActiveMQComponent;
 import org.apache.camel.CamelContext;
+import org.apache.camel.ProducerTemplate;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.impl.DefaultCamelContext;
 import org.junit.After;
-import org.junit.Before;
 import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -33,6 +33,16 @@ public class AMQ2240Test {
 
     private static final Logger LOG = LoggerFactory.getLogger(AMQ2240Test.class);
 
+    private CamelContext camelContext = null;
+
+    @After
+    public void destroyCamelContext() throws Exception {
+        if (camelContext != null) {
+            camelContext.stop();
+            camelContext = null;
+        }
+    }
+
     @Test
     public void testBadVMTransportOptionsJMSPrefix() throws Exception {
 
@@ -54,12 +64,27 @@ public class AMQ2240Test {
 
     @Test
     public void testBadVMTransportOptionsBrokerPrefix() throws Exception {
-        try{
+        try {
+
             final String vmUri = "vm://localhost?" +
                 "broker.XXX=foo&broker.persistent=XXX&broker.useJmx=false";
 
             LOG.info("creating context with bad URI: " + vmUri);
-            ActiveMQComponent.activeMQComponent(vmUri).start();
+            ActiveMQComponent amq = ActiveMQComponent.activeMQComponent(vmUri);
+
+            camelContext = new DefaultCamelContext();
+            camelContext.addComponent("activemq", amq);
+            final String queueEndpointName = "activemq:queuetest.Queue";
+            camelContext.addRoutes(new RouteBuilder() {
+                @Override
+                public void configure() throws Exception {
+                    from(queueEndpointName).bean(Consumer.class, "consume");
+                }
+            });
+
+            camelContext.start();
+            final ProducerTemplate producerTemplate = camelContext.createProducerTemplate();
+            producerTemplate.sendBody(queueEndpointName, "message");
 
             fail("Should have received an exception from the bad URI.");
         } catch(Exception e) {