svn commit: r1157531 - /camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java

[da...@apache.org]

Author: davsclaus
Date: Sun Aug 14 13:45:06 2011
New Revision: 1157531

URL: http://svn.apache.org/viewvc?rev=1157531&view=rev
Log:
Indicate in thread names from JettyHttpComponent they are from this component, to differentiate them with other Jetty usages in the JVM.

Modified:
    camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java

Modified: camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java?rev=1157531&r1=1157530&r2=1157531&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java (original)
+++ camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java Sun Aug 14 13:45:06 2011
@@ -21,7 +21,6 @@ import java.net.URI;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-
 import javax.management.MBeanServer;
 import javax.servlet.Filter;
 
@@ -593,6 +592,8 @@ public class JettyHttpComponent extends 
             if (httpClientMaxThreads != null) {
                 qtp.setMaxThreads(httpClientMaxThreads.intValue());
             }
+            // let the thread names indicate they are from this component
+            qtp.setName("CamelJetty(" + ObjectHelper.getIdentityHashCode(this) + ")");
             try {
                 qtp.start();
             } catch (Exception e) {
@@ -603,7 +604,7 @@ public class JettyHttpComponent extends 
         httpClient.setThreadPool(getHttpClientThreadPool());
         
         if (this.sslContextParameters != null) {
-            ((CamelHttpClient) httpClient).setSSLContext(this.sslContextParameters.createSSLContext());
+            httpClient.setSSLContext(this.sslContextParameters.createSSLContext());
         }
         
         return httpClient;