Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1518366 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2013-08-28 20:27:13 +00:00
parent 30fc80ccc9
commit 84ce96b2dd
1 changed files with 30 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
activemq-camel/src/test/java/org/apache/activemq/camel/AMQ2240Test.java
View File

@ -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) {