Repository: camel Updated Branches: refs/heads/master 452a1c0e1 -> fe80773ee
Polished Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3550cbb3 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3550cbb3 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3550cbb3 Branch: refs/heads/master Commit: 3550cbb3e82e705309dbbe4bb86879a3fce0becb Parents: 452a1c0 Author: Claus Ibsen <davscl...@apache.org> Authored: Sun Dec 21 10:09:28 2014 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sun Dec 21 10:09:28 2014 +0100 ---------------------------------------------------------------------- .../org/apache/camel/component/jetty/JettyHttpProducer.java | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3550cbb3/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java index eca9ee6..93f4380 100644 --- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java +++ b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyHttpProducer.java @@ -34,9 +34,8 @@ import org.apache.camel.Message; import org.apache.camel.component.http.HttpConstants; import org.apache.camel.component.http.HttpMethods; import org.apache.camel.component.http.helper.HttpHelper; -import org.apache.camel.impl.DefaultProducer; +import org.apache.camel.impl.DefaultAsyncProducer; import org.apache.camel.spi.HeaderFilterStrategy; -import org.apache.camel.util.AsyncProcessorHelper; import org.apache.camel.util.ExchangeHelper; import org.apache.camel.util.IOHelper; import org.apache.camel.util.ObjectHelper; @@ -49,7 +48,7 @@ import org.slf4j.LoggerFactory; /** * @version */ -public class JettyHttpProducer extends DefaultProducer implements AsyncProcessor { +public class JettyHttpProducer extends DefaultAsyncProducer implements AsyncProcessor { private static final Logger LOG = LoggerFactory.getLogger(JettyHttpProducer.class); private HttpClient client; private boolean sharedClient; @@ -83,10 +82,6 @@ public class JettyHttpProducer extends DefaultProducer implements AsyncProcessor return (JettyHttpEndpoint) super.getEndpoint(); } - public void process(Exchange exchange) throws Exception { - AsyncProcessorHelper.process(this, exchange); - } - public boolean process(Exchange exchange, final AsyncCallback callback) { try { JettyContentExchange httpExchange = createHttpExchange(exchange, callback);
