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

Removing two tests as they do not actually test anything

This commit is contained in:
Christian Schneider 2017-04-05 15:27:04 +02:00
parent b64ac1dd77
commit 548403ad99
1 changed files with 3 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
activemq-camel/src/test/java/org/apache/activemq/camel/component/ActiveMQRouteTest.java
View File

@ -16,8 +16,6 @@
*/ */
package org.apache.activemq.camel.component; package org.apache.activemq.camel.component;
import java.util.concurrent.TimeUnit;
import org.apache.camel.CamelContext; import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder; import org.apache.camel.builder.RouteBuilder;
@ -33,17 +31,16 @@ import static org.apache.activemq.camel.component.ActiveMQComponent.activeMQComp
* *
*/ */
public class ActiveMQRouteTest extends CamelTestSupport { public class ActiveMQRouteTest extends CamelTestSupport {
private static final String EXPECTED_BODY = "Hello there!";
protected MockEndpoint resultEndpoint; protected MockEndpoint resultEndpoint;
protected String startEndpointUri = "activemq:queue:test.a"; protected String startEndpointUri = "activemq:queue:test.a";
@Test @Test
public void testJmsRouteWithTextMessage() throws Exception { public void testJmsRouteWithTextMessage() throws Exception {
String expectedBody = "Hello there!"; resultEndpoint.expectedBodiesReceived(EXPECTED_BODY);
resultEndpoint.expectedBodiesReceived(expectedBody);
resultEndpoint.message(0).header("cheese").isEqualTo(123); resultEndpoint.message(0).header("cheese").isEqualTo(123);
sendExchange(expectedBody); sendExchange(EXPECTED_BODY);
resultEndpoint.assertIsSatisfied(); resultEndpoint.assertIsSatisfied();
} }
@ -69,36 +66,6 @@ public class ActiveMQRouteTest extends CamelTestSupport {
return camelContext; return camelContext;
} }
@Test
public void testInvalidDestinationOptionOnConsumer() throws Exception {
getMockEndpoint("mock:result").expectedMessageCount(0);
assertMockEndpointsSatisfied(1, TimeUnit.SECONDS);
try {
new RouteBuilder() {
public void configure() throws Exception {
from("activemq:queue:foo?destination.consumer.exclusive=true&destination.consumer.unknown=foo")
.to("mock:result");
}
};
} catch (Exception e) {
fail("Should not have accepted bad destination options.");
}
}
@Test
public void testInvalidDestinationOptionOnProducer() throws Exception {
try {
new RouteBuilder() {
public void configure() throws Exception {
from("activemq:queue:foo")
.to("activemq:queue:bar?destination.producer.exclusive=true");
}
};
} catch (Exception e) {
fail("Should not have accepted bad destination options.");
}
}
protected RouteBuilder createRouteBuilder() throws Exception { protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() { return new RouteBuilder() {
public void configure() throws Exception { public void configure() throws Exception {