You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by he...@apache.org on 2015/12/01 15:24:09 UTC
camel git commit: [CAMEL-9381] Removed AMQP 0.9 tests.
Repository: camel
Updated Branches:
refs/heads/master 87dbfa08d -> 1f2127362
[CAMEL-9381] Removed AMQP 0.9 tests.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1f212736
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1f212736
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1f212736
Branch: refs/heads/master
Commit: 1f2127362409efa41b75d2b5bbf555b2ec6c6c99
Parents: 87dbfa0
Author: Henryk Konsek <he...@gmail.com>
Authored: Tue Dec 1 15:24:05 2015 +0100
Committer: Henryk Konsek <he...@gmail.com>
Committed: Tue Dec 1 15:24:05 2015 +0100
----------------------------------------------------------------------
.../apache/camel/component/amqp/AMQPRouteTest.java | 14 +-------------
1 file changed, 1 insertion(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/1f212736/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
----------------------------------------------------------------------
diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
index b388698..1b63ad8 100644
--- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
+++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
@@ -27,9 +27,6 @@ import org.junit.Test;
import static org.apache.camel.component.amqp.AMQPComponent.amqpComponent;
-/**
- * @version
- */
public class AMQPRouteTest extends CamelTestSupport {
protected MockEndpoint resultEndpoint;
protected Broker broker;
@@ -38,11 +35,6 @@ public class AMQPRouteTest extends CamelTestSupport {
public void testJmsRouteWithTextMessage() throws Exception {
String expectedBody = "Hello there!";
- resultEndpoint.expectedMessageCount(1);
- resultEndpoint.message(0).header("cheese").isEqualTo(123);
- template.sendBodyAndHeader("amqp0-9:queue:ping", expectedBody, "cheese", 123);
- resultEndpoint.assertIsSatisfied();
-
resultEndpoint.reset();
resultEndpoint.expectedMessageCount(1);
resultEndpoint.message(0).header("cheese").isEqualTo(123);
@@ -73,7 +65,6 @@ public class AMQPRouteTest extends CamelTestSupport {
protected CamelContext createCamelContext() throws Exception {
CamelContext camelContext = super.createCamelContext();
- camelContext.addComponent("amqp0-9", amqpComponent("amqp://guest:guest@/test?brokerlist='tcp://localhost:5672'", true));
camelContext.addComponent("amqp1-0", amqpComponent("amqp://guest:guest@localhost:5672?remote-host=test", false));
return camelContext;
}
@@ -81,14 +72,11 @@ public class AMQPRouteTest extends CamelTestSupport {
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
public void configure() throws Exception {
- from("amqp0-9:queue:ping")
- .to("log:routing")
- .to("mock:result");
-
from("amqp1-0:queue:ping")
.to("log:routing")
.to("mock:result");
}
};
}
+
}