You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2011/09/12 15:53:05 UTC
svn commit: r1169745 - in /camel/trunk/components/camel-cxf/src:
main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
test/java/org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest.java
Author: hadrian
Date: Mon Sep 12 13:53:05 2011
New Revision: 1169745
URL: http://svn.apache.org/viewvc?rev=1169745&view=rev
Log:
Checkstyle fix
Modified:
camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest.java
Modified: camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java?rev=1169745&r1=1169744&r2=1169745&view=diff
==============================================================================
--- camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java (original)
+++ camel/trunk/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/jaxrs/CxfRsEndpoint.java Mon Sep 12 13:53:05 2011
@@ -55,7 +55,7 @@ public class CxfRsEndpoint extends Defau
private AtomicBoolean bindingInitialized = new AtomicBoolean(false);
private AtomicBoolean getBusHasBeenCalled = new AtomicBoolean(false);
- private boolean isSetDefaultBus;
+ private boolean isSetDefaultBus;
public CxfRsEndpoint(String endpointUri, CamelContext camelContext) {
super(endpointUri, camelContext);
Modified: camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest.java?rev=1169745&r1=1169744&r2=1169745&view=diff
==============================================================================
--- camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest.java (original)
+++ camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest.java Mon Sep 12 13:53:05 2011
@@ -46,41 +46,36 @@ public class CxfRsProducerClientFactoryC
@Before
public void setUp() throws Exception {
- AbstractApplicationContext ac = new ClassPathXmlApplicationContext("org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest1.xml");
- context1 = SpringCamelContext.springCamelContext(ac, false);
- context1.start();
-
- template1 = context1.createProducerTemplate();
- template1.start();
-
- ac = new ClassPathXmlApplicationContext("org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest2.xml");
- context2 = SpringCamelContext.springCamelContext(ac, false);
- context2.start();
-
- template2 = context2.createProducerTemplate();
- template2.start();
-
+ AbstractApplicationContext ac = new ClassPathXmlApplicationContext("org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest1.xml");
+ context1 = SpringCamelContext.springCamelContext(ac, false);
+ context1.start();
+ template1 = context1.createProducerTemplate();
+ template1.start();
+
+ ac = new ClassPathXmlApplicationContext("org/apache/camel/component/cxf/jaxrs/CxfRsProducerClientFactoryCacheTest2.xml");
+ context2 = SpringCamelContext.springCamelContext(ac, false);
+ context2.start();
+
+ template2 = context2.createProducerTemplate();
+ template2.start();
}
@After
public void tearDown() throws Exception {
- context1.stop();
- template1.stop();
-
- context2.stop();
- template2.stop();
-
+ context1.stop();
+ template1.stop();
+
+ context2.stop();
+ template2.stop();
}
@Test
public void testGetConstumerWithHttpCentralClientAPI() throws Exception {
-
- doRunTest(template2);
- doRunTest(template1);
-
+ doRunTest(template2);
+ doRunTest(template1);
}
- private void doRunTest(ProducerTemplate template) {
+ private void doRunTest(ProducerTemplate template) {
Exchange exchange = template.send("direct://http", new Processor() {
public void process(Exchange exchange) throws Exception {
exchange.setPattern(ExchangePattern.InOut);
@@ -100,10 +95,9 @@ public class CxfRsProducerClientFactoryC
assertEquals("Get a wrong customer id ", String.valueOf(response.getId()), "123");
assertEquals("Get a wrong customer name", response.getName(), "John");
assertEquals("Get a wrong response code", 200, exchange.getOut().getHeader(Exchange.HTTP_RESPONSE_CODE));
-
- }
+ }
- public int getPort1() {
+ public int getPort1() {
return port1;
}
}