You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2010/05/27 16:30:40 UTC
svn commit: r948848 -
/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java
Author: davsclaus
Date: Thu May 27 14:30:40 2010
New Revision: 948848
URL: http://svn.apache.org/viewvc?rev=948848&view=rev
Log:
Added test for fixed replyTo in endpoint uri
Added:
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java
- copied, changed from r948831, camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java
Copied: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java (from r948831, camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java)
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java?p2=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java&p1=camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java&r1=948831&r2=948848&rev=948848&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyManualReplyTest.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyFixedReplyToInEndpointTest.java Thu May 27 14:30:40 2010
@@ -16,79 +16,84 @@
*/
package org.apache.camel.component.jms;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
import javax.jms.ConnectionFactory;
-import javax.jms.Destination;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.Session;
-import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
-import org.apache.activemq.command.ActiveMQQueue;
-import org.apache.camel.Body;
import org.apache.camel.CamelContext;
-import org.apache.camel.Consume;
-import org.apache.camel.Header;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;
-import org.springframework.jms.core.JmsTemplate;
-import org.springframework.jms.core.MessageCreator;
import static org.apache.camel.component.jms.JmsComponent.jmsComponentClientAcknowledge;
/**
* @version $Revision$
*/
-public class JmsRequestReplyManualReplyTest extends CamelTestSupport {
+public class JmsRequestReplyFixedReplyToInEndpointTest extends CamelTestSupport {
- private static volatile String tempName;
- private CountDownLatch latch = new CountDownLatch(1);
- private JmsTemplate jms;
-
- @Override
- public boolean isUseRouteBuilder() {
- return false;
+ @Test
+ public void testJmsRequestReplyTempReplyTo() throws Exception {
+ Exchange reply = template.request("activemq:queue:foo", new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setBody("World");
+ }
+ });
+ assertEquals("Hello World", reply.getOut().getBody());
+ assertTrue("Should have headers", reply.getOut().hasHeaders());
+ String replyTo = reply.getOut().getHeader("JMSReplyTo", String.class);
+ assertTrue("Should be a temp queue", replyTo.startsWith("temp-queue"));
}
- @Consume(uri = "activemq:queue:foo")
- public void doSomething(@Header("JMSReplyTo") Destination jmsReplyTo, @Body String body) throws Exception {
- assertEquals("Hello World", body);
-
- String endpointName = "activemq:" + jmsReplyTo.toString();
- endpointName = endpointName.replaceAll("//", ":");
-
- tempName = endpointName;
- latch.countDown();
-
- template.sendBody(tempName, "Bye World");
+ @Test
+ public void testJmsRequestReplyFixedReplyToInEndpoint() throws Exception {
+ Exchange reply = template.request("activemq:queue:foo?replyTo=bar", new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setBody("World");
+ }
+ });
+ assertEquals("Hello World", reply.getOut().getBody());
+ assertTrue("Should have headers", reply.getOut().hasHeaders());
+ assertEquals("queue://bar", reply.getOut().getHeader("JMSReplyTo", String.class));
}
@Test
- public void testManualRequestReply() throws Exception {
- // send using pure JMS API to set a custom JMSReplyTo
- jms.send(new ActiveMQQueue("foo"), new MessageCreator() {
- public Message createMessage(Session session) throws JMSException {
- TextMessage msg = session.createTextMessage("Hello World");
- msg.setJMSReplyTo(new ActiveMQQueue("bar"));
- return msg;
+ public void testJmsRequestReplyFixedReplyToInEndpointTwoMessages() throws Exception {
+ Exchange reply = template.request("activemq:queue:foo?replyTo=bar", new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setBody("World");
}
});
-
- latch.await(5, TimeUnit.SECONDS);
- String reply = consumer.receiveBody(tempName, 5000, String.class);
- assertEquals("Bye World", reply);
+ assertEquals("Hello World", reply.getOut().getBody());
+ assertTrue("Should have headers", reply.getOut().hasHeaders());
+ assertEquals("queue://bar", reply.getOut().getHeader("JMSReplyTo", String.class));
+
+ reply = template.request("activemq:queue:foo?replyTo=bar", new Processor() {
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setBody("Moon");
+ }
+ });
+ assertEquals("Hello Moon", reply.getOut().getBody());
+ assertTrue("Should have headers", reply.getOut().hasHeaders());
+ assertEquals("queue://bar", reply.getOut().getHeader("JMSReplyTo", String.class));
}
protected CamelContext createCamelContext() throws Exception {
CamelContext camelContext = super.createCamelContext();
-
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");
camelContext.addComponent("activemq", jmsComponentClientAcknowledge(connectionFactory));
-
- jms = new JmsTemplate(connectionFactory);
return camelContext;
}
-}
+ @Override
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+ from("activemq:queue:foo")
+ .transform(body().prepend("Hello "));
+ }
+ };
+ }
+}
\ No newline at end of file