camel-commits mailing list archives

Author: romkal
Date: Mon Jan 21 17:08:02 2008
New Revision: 614080

URL: http://svn.apache.org/viewvc?rev=614080&view=rev
Log:
CAMEL-304 : camel-jetty changed due to changes in camel-http

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

Modified: activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java?rev=614080&r1=614079&r2=614080&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
(original)
+++ activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
Mon Jan 21 17:08:02 2008
@@ -69,7 +69,7 @@
     @Override
     protected Endpoint<HttpExchange> createEndpoint(String uri, String remaining, Map
parameters) throws Exception {
         URI httpURL = uri.startsWith("jetty:") ? new URI(remaining) : new URI(uri);
-        return new JettyHttpEndpoint(this, uri, httpURL);
+        return new JettyHttpEndpoint(this, uri, httpURL, getHttpConnectionManager());
     }
 
     /**

Modified: activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java?rev=614080&r1=614079&r2=614080&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
(original)
+++ activemq/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
Mon Jan 21 17:08:02 2008
@@ -28,6 +28,7 @@
 import org.apache.camel.component.http.HttpEndpoint;
 import org.apache.camel.component.http.HttpExchange;
 import org.apache.camel.impl.EventDrivenPollingConsumer;
+import org.apache.commons.httpclient.HttpConnectionManager;
 
 /**
  * @version $Revision: 1.1 $
@@ -35,8 +36,8 @@
 public class JettyHttpEndpoint extends HttpEndpoint {
     private JettyHttpComponent component;
 
-    public JettyHttpEndpoint(JettyHttpComponent component, String uri, URI httpURL) throws
URISyntaxException {
-        super(uri, component, httpURL);
+    public JettyHttpEndpoint(JettyHttpComponent component, String uri, URI httpURL, HttpConnectionManager
httpConnectionManager) throws URISyntaxException {
+        super(uri, component, httpURL, httpConnectionManager);
         this.component = component;
     }
 
@@ -53,7 +54,7 @@
 
     @Override
     public PollingConsumer<HttpExchange> createPollingConsumer() throws Exception {
-        return new EventDrivenPollingConsumer(this);
+        return new EventDrivenPollingConsumer<HttpExchange>(this);
     }
 
     @Override