Author: ningjiang
Date: Tue Aug 23 11:20:41 2011
New Revision: 1160632
URL: http://svn.apache.org/viewvc?rev=1160632&view=rev
Log:
Enable the test of Netty2978Issue
Modified:
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Netty2978IssueTest.java
Modified:
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Netty2978IssueTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Netty2978IssueTest.java?rev=1160632&r1=1160631&r2=1160632&view=diff
==============================================================================
---
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Netty2978IssueTest.java
(original)
+++
camel/trunk/components/camel-netty/src/test/java/org/apache/camel/component/netty/Netty2978IssueTest.java
Tue Aug 23 11:20:41 2011
@@ -32,6 +32,7 @@ import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.properties.PropertiesComponent;
import org.apache.camel.impl.DefaultCamelContext;
import org.junit.Ignore;
import org.junit.Test;
@@ -39,12 +40,11 @@ import org.junit.Test;
/**
* @version
*/
-@Ignore
public class Netty2978IssueTest extends BaseNettyTest {
@Test
public void testNetty2978() throws Exception {
- CamelClient client = new CamelClient();
+ CamelClient client = new CamelClient(context);
try {
for (int i = 0; i < 1000; i++) {
Object reply = client.lookup(i);
@@ -57,7 +57,7 @@ public class Netty2978IssueTest extends
@Test
public void testNetty2978Concurrent() throws Exception {
- final CamelClient client = new CamelClient();
+ final CamelClient client = new CamelClient(context);
try {
final List<Callable<String>> callables = new
ArrayList<Callable<String>>();
for (int count = 0; count < 1000; count++) {
@@ -104,19 +104,18 @@ public class Netty2978IssueTest extends
}
private static final class CamelClient {
- private final CamelContext context;
+ private final CamelContext camelContext;
private final Endpoint endpoint;
private final ProducerTemplate producerTemplate;
- public CamelClient() {
- this.context = new DefaultCamelContext();
- this.endpoint =
context.getEndpoint("netty:tcp://localhost:{{port}}?sync=true");
- this.producerTemplate = context.createProducerTemplate();
+ public CamelClient(CamelContext camelContext) {
+ this.camelContext = camelContext;
+ this.endpoint =
camelContext.getEndpoint("netty:tcp://localhost:{{port}}?sync=true");
+ this.producerTemplate = camelContext.createProducerTemplate();
}
public void close() throws Exception {
producerTemplate.stop();
- context.stop();
}
public String lookup(int num) {
