This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch exchange-factory in repository https://gitbox.apache.org/repos/asf/camel.git
commit c46d26549253ad71f2dcb66402d20cf845f02a6b Author: Claus Ibsen <[email protected]> AuthorDate: Mon Feb 22 10:47:35 2021 +0100 CAMEL-16222: PooledExchangeFactory experiment --- .../src/main/java/org/apache/camel/component/nats/NatsConsumer.java | 2 +- .../main/java/org/apache/camel/oaipmh/handler/AbstractHandler.java | 1 - .../src/main/java/org/apache/camel/oaipmh/handler/Harvester.java | 6 ------ .../camel/component/sip/listener/SipSubscriptionListener.java | 1 - .../main/java/org/apache/camel/component/slack/SlackConsumer.java | 1 - .../src/main/java/org/apache/camel/component/sql/SqlConsumer.java | 1 - 6 files changed, 1 insertion(+), 11 deletions(-) diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java index 0c78677..84cc5c1 100644 --- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java +++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsConsumer.java @@ -174,7 +174,7 @@ public class NatsConsumer extends DefaultConsumer { con.publish(msg.getReplyTo(), data); } } - } catch (Exception e){ + } catch (Exception e) { getExceptionHandler().handleException("Error during processing", exchange, e); } finally { releaseExchange(exchange, false); diff --git a/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/AbstractHandler.java b/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/AbstractHandler.java index c204028..a68a551 100644 --- a/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/AbstractHandler.java +++ b/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/AbstractHandler.java @@ -20,7 +20,6 @@ import org.apache.camel.Consumer; import org.apache.camel.Endpoint; import org.apache.camel.Exchange; import org.apache.camel.Processor; -import org.apache.camel.RuntimeCamelException; import org.apache.camel.oaipmh.component.OAIPMHConsumer; import org.apache.camel.oaipmh.model.OAIPMHResponse; import org.apache.camel.spi.ExceptionHandler; diff --git a/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/Harvester.java b/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/Harvester.java index 84a795b..b05ebc1 100644 --- a/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/Harvester.java +++ b/components/camel-oaipmh/src/main/java/org/apache/camel/oaipmh/handler/Harvester.java @@ -16,16 +16,10 @@ */ package org.apache.camel.oaipmh.handler; -import java.io.IOException; import java.net.URI; -import java.net.URISyntaxException; import java.util.List; import java.util.Optional; -import javax.xml.parsers.ParserConfigurationException; - -import org.xml.sax.SAXException; - import org.apache.camel.oaipmh.component.model.OAIPMHVerb; import org.apache.camel.oaipmh.model.OAIPMHResponse; import org.apache.camel.oaipmh.utils.OAIPMHHttpClient; diff --git a/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipSubscriptionListener.java b/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipSubscriptionListener.java index 6738ed8..2392eb6 100644 --- a/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipSubscriptionListener.java +++ b/components/camel-sip/src/main/java/org/apache/camel/component/sip/listener/SipSubscriptionListener.java @@ -31,7 +31,6 @@ import javax.sip.header.ViaHeader; import javax.sip.message.Request; import javax.sip.message.Response; -import org.apache.camel.CamelException; import org.apache.camel.Exchange; import org.apache.camel.ExchangePattern; import org.apache.camel.component.sip.SipSubscriber; diff --git a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java index 8ea304c..fde7f10 100644 --- a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java +++ b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackConsumer.java @@ -25,7 +25,6 @@ import java.util.List; import java.util.Queue; import org.apache.camel.Exchange; -import org.apache.camel.ExchangePattern; import org.apache.camel.Message; import org.apache.camel.Processor; import org.apache.camel.RuntimeCamelException; diff --git a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java index 145b7f1..78635f4 100644 --- a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java +++ b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlConsumer.java @@ -25,7 +25,6 @@ import java.util.List; import java.util.Queue; import org.apache.camel.Exchange; -import org.apache.camel.ExchangePattern; import org.apache.camel.Message; import org.apache.camel.Processor; import org.apache.camel.RollbackExchangeException;
