This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new 14a5fdf (chores) Cleanup unused throws (#5743) 14a5fdf is described below commit 14a5fdf7aa8249daf0d430b3fe3080bda7b48e96 Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com> AuthorDate: Wed Jun 23 16:34:59 2021 +0200 (chores) Cleanup unused throws (#5743) components: components/camel-etcd, components/camel-jaxb, components/camel-jclouds, components/camel-jdbc, components/camel-jmx, components/camel-jsonpath, components/camel-mail, omponents/camel-master, components/camel-milom, components/camel-mina, components/camel-mllp, components/camel-mock, components/camel-mybatis, components/camel-optaplanner, components/camel-pgevent, components/camel-printer, components/camel-quartz, components/camel-quickfix, components/camel-reactive-streams, components/camel-rest, components/camel-saxon, components/camel-seda, components/camel-servicenow, components/camel-sip, components/camel-smpp, components/camel-spring-integration, components/camel-spring-javaconfig, components/camel-spring-main, components/camel-spring-rabbitmq, components/camel-spring-xml, components/camel-stream, components/camel-thrift, components/camel-undertow, components/camel-websocket, components/camel-weka, components/camel-xmpp --- .../camel/component/etcd/AbstractEtcdComponent.java | 2 +- .../jaxb/JaxbRestBindingJaxbDataFormatFactory.java | 3 +-- .../camel/component/jclouds/JcloudsBlobStoreHelper.java | 10 +++++----- .../org/apache/camel/component/jdbc/JdbcProducer.java | 2 +- .../java/org/apache/camel/component/jmx/JMXConsumer.java | 2 +- .../main/java/org/apache/camel/jsonpath/JsonStream.java | 2 +- .../org/apache/camel/component/mail/MailEndpoint.java | 2 +- .../apache/camel/component/master/MasterConsumer.java | 2 +- .../component/milo/client/MiloClientConnection.java | 2 +- .../component/mina/MinaUdpProtocolCodecFactory.java | 4 +--- .../camel/component/mllp/MllpTcpClientProducer.java | 3 +-- .../org/apache/camel/component/mock/MockEndpoint.java | 2 +- .../camel/component/mybatis/BaseMyBatisEndpoint.java | 4 +--- .../apache/camel/component/mybatis/MyBatisProducer.java | 16 ++++++++-------- .../camel/component/optaplanner/OptaPlannerProducer.java | 2 +- .../apache/camel/component/pgevent/PgEventProducer.java | 2 +- .../camel/component/printer/PrinterConfiguration.java | 5 ++--- .../camel/component/printer/PrinterOperations.java | 2 +- .../apache/camel/component/printer/PrinterProducer.java | 4 ++-- .../apache/camel/component/quartz/QuartzEndpoint.java | 2 +- .../routepolicy/quartz/CronScheduledRoutePolicy.java | 2 +- .../camel/routepolicy/quartz/ScheduledRoutePolicy.java | 5 ++--- .../routepolicy/quartz/SimpleScheduledRoutePolicy.java | 2 +- .../camel/component/quickfixj/MessageCorrelator.java | 3 +-- .../camel/component/quickfixj/QuickfixjComponent.java | 2 +- .../quickfixj/converter/QuickfixjConverters.java | 2 +- .../reactive/streams/engine/CamelSubscription.java | 2 +- .../org/apache/camel/component/rest/RestProducer.java | 3 +-- .../org/apache/camel/component/xquery/XQueryBuilder.java | 5 ++--- .../org/apache/camel/component/seda/SedaEndpoint.java | 2 +- .../servicenow/AbstractServiceNowProcessor.java | 2 +- .../camel/component/servicenow/ServiceNowEndpoint.java | 2 +- .../org/apache/camel/component/sip/SipConfiguration.java | 4 ++-- .../org/apache/camel/component/smpp/SmppComponent.java | 2 +- .../spring/integration/adapter/CamelTargetAdapter.java | 2 +- .../converter/SpringIntegrationConverter.java | 8 +++----- .../camel/spring/javaconfig/CamelConfiguration.java | 6 +++--- .../src/main/java/org/apache/camel/spring/Main.java | 2 +- .../component/springrabbit/SpringRabbitMQEndpoint.java | 2 +- .../camel/spring/xml/PackageScanRouteBuilderFinder.java | 5 ++--- .../apache/camel/component/stream/StreamProducer.java | 2 +- .../apache/camel/component/thrift/ThriftEndpoint.java | 2 +- .../apache/camel/component/thrift/ThriftProducer.java | 2 +- .../apache/camel/dataformat/thrift/ThriftDataFormat.java | 2 +- .../camel/component/websocket/WebsocketComponent.java | 2 +- .../camel/component/websocket/WebsocketProducer.java | 3 +-- .../org/apache/camel/component/weka/WekaProducer.java | 14 +++++++------- .../org/apache/camel/component/xmpp/XmppConsumer.java | 4 ++-- .../org/apache/camel/component/xmpp/XmppEndpoint.java | 6 +++--- .../camel/component/xmpp/XmppGroupChatProducer.java | 2 +- 50 files changed, 80 insertions(+), 95 deletions(-) diff --git a/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/AbstractEtcdComponent.java b/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/AbstractEtcdComponent.java index 6a603e4..640faca 100644 --- a/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/AbstractEtcdComponent.java +++ b/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/AbstractEtcdComponent.java @@ -66,7 +66,7 @@ public abstract class AbstractEtcdComponent extends DefaultComponent implements this.useGlobalSslContextParameters = useGlobalSslContextParameters; } - protected EtcdConfiguration loadConfiguration(Map<String, Object> parameters) throws Exception { + protected EtcdConfiguration loadConfiguration(Map<String, Object> parameters) { EtcdConfiguration configuration = Optional.ofNullable(this.configuration).orElseGet(EtcdConfiguration::new).copy(); configuration.setCamelContext(getCamelContext()); diff --git a/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbRestBindingJaxbDataFormatFactory.java b/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbRestBindingJaxbDataFormatFactory.java index 4f036d5..4e51b9e 100644 --- a/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbRestBindingJaxbDataFormatFactory.java +++ b/components/camel-jaxb/src/main/java/org/apache/camel/converter/jaxb/JaxbRestBindingJaxbDataFormatFactory.java @@ -97,8 +97,7 @@ public class JaxbRestBindingJaxbDataFormatFactory implements RestBindingJaxbData outBuilder.bind(); } - private void setAdditionalConfiguration(RestConfiguration config, String prefix, PropertyBindingSupport.Builder builder) - throws Exception { + private void setAdditionalConfiguration(RestConfiguration config, String prefix, PropertyBindingSupport.Builder builder) { if (config.getDataFormatProperties() != null && !config.getDataFormatProperties().isEmpty()) { // must use a copy as otherwise the options gets removed during // introspection setProperties diff --git a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java index f74ce00..4f7cbe3 100644 --- a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java +++ b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsBlobStoreHelper.java @@ -111,7 +111,7 @@ public final class JcloudsBlobStoreHelper { /** * Remove a specific blob from a {@link BlobStore} */ - public static void removeBlob(BlobStore blobStore, String container, String blobName) throws IOException { + public static void removeBlob(BlobStore blobStore, String container, String blobName) { if (!Strings.isNullOrEmpty(blobName)) { blobStore.removeBlob(container, blobName); } @@ -120,21 +120,21 @@ public final class JcloudsBlobStoreHelper { /** * Clear a {@link BlobStore} specific container */ - public static void clearContainer(BlobStore blobStore, String container) throws IOException { + public static void clearContainer(BlobStore blobStore, String container) { blobStore.clearContainer(container); } /** * Delete a {@link BlobStore} specific container */ - public static void deleteContainer(BlobStore blobStore, String container) throws IOException { + public static void deleteContainer(BlobStore blobStore, String container) { blobStore.deleteContainer(container); } /** * Check if a {@link BlobStore} specific container exists or not */ - public static boolean containerExists(BlobStore blobStore, String container) throws IOException { + public static boolean containerExists(BlobStore blobStore, String container) { boolean result = blobStore.containerExists(container); return result; } @@ -142,7 +142,7 @@ public final class JcloudsBlobStoreHelper { /** * Delete a list of {@link BlobStore} blob */ - public static void removeBlobs(BlobStore blobStore, String container, List blobNames) throws IOException { + public static void removeBlobs(BlobStore blobStore, String container, List blobNames) { blobStore.removeBlobs(container, blobNames); } } diff --git a/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java b/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java index caa6514..44e8ce1 100644 --- a/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java +++ b/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcProducer.java @@ -48,7 +48,7 @@ public class JdbcProducer extends DefaultProducer { private final Map<String, Object> parameters; public JdbcProducer(JdbcEndpoint endpoint, DataSource dataSource, ConnectionStrategy connectionStrategy, - int readSize, Map<String, Object> parameters) throws Exception { + int readSize, Map<String, Object> parameters) { super(endpoint); this.dataSource = dataSource; this.connectionStrategy = connectionStrategy; diff --git a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java index 7fa7853..a2ed5dc 100644 --- a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java +++ b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java @@ -166,7 +166,7 @@ public class JMXConsumer extends DefaultConsumer implements NotificationListener /** * Schedules execution of the doStart() operation to occur again after the reconnect delay */ - protected void scheduleDelayedStart() throws Exception { + protected void scheduleDelayedStart() { Runnable startRunnable = new Runnable() { @Override public void run() { diff --git a/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java b/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java index 79089fe..287e7d9 100644 --- a/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java +++ b/components/camel-jsonpath/src/main/java/org/apache/camel/jsonpath/JsonStream.java @@ -177,7 +177,7 @@ public class JsonStream extends FilterInputStream { } } - private CharConversionException getExceptionUnsupportedUCS4(String type) throws IOException { + private CharConversionException getExceptionUnsupportedUCS4(String type) { return new CharConversionException("Unsupported UCS-4 endianness (" + type + ") detected"); } diff --git a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java index c7723cd..a630fa66 100644 --- a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java +++ b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java @@ -97,7 +97,7 @@ public class MailEndpoint extends ScheduledPollEndpoint implements HeaderFilterS /** * Creates a producer using the given sender */ - public Producer createProducer(JavaMailSender sender) throws Exception { + public Producer createProducer(JavaMailSender sender) { return new MailProducer(this, sender); } diff --git a/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java b/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java index d84b743..8489ebe 100644 --- a/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java +++ b/components/camel-master/src/main/java/org/apache/camel/component/master/MasterConsumer.java @@ -130,7 +130,7 @@ public class MasterConsumer extends DefaultConsumer { LOG.info("Leadership taken. Consumer started: {}", delegatedEndpoint); } - private synchronized void onLeadershipLost() throws Exception { + private synchronized void onLeadershipLost() { ServiceHelper.stopAndShutdownServices(delegatedConsumer, delegatedEndpoint); delegatedConsumer = null; diff --git a/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientConnection.java b/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientConnection.java index 907992d..5cbf405 100644 --- a/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientConnection.java +++ b/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientConnection.java @@ -51,7 +51,7 @@ public class MiloClientConnection implements AutoCloseable { return configuration; } - protected void init() throws Exception { + protected void init() { this.manager = new SubscriptionManager(this.configuration, Stack.sharedScheduledExecutor(), 10_000); } diff --git a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaUdpProtocolCodecFactory.java b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaUdpProtocolCodecFactory.java index 75e586f..2c2ae80 100644 --- a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaUdpProtocolCodecFactory.java +++ b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaUdpProtocolCodecFactory.java @@ -16,8 +16,6 @@ */ package org.apache.camel.component.mina; -import java.nio.charset.CharacterCodingException; - import org.apache.camel.CamelContext; import org.apache.camel.NoTypeConversionAvailableException; import org.apache.mina.core.buffer.IoBuffer; @@ -73,7 +71,7 @@ public class MinaUdpProtocolCodecFactory implements ProtocolCodecFactory { }; } - private IoBuffer toIoBuffer(Object message) throws CharacterCodingException, NoTypeConversionAvailableException { + private IoBuffer toIoBuffer(Object message) throws NoTypeConversionAvailableException { //try to convert it to a byte array byte[] value = context.getTypeConverter().tryConvertTo(byte[].class, message); if (value != null) { diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java index e2fc479..82cde9f 100644 --- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java +++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpTcpClientProducer.java @@ -20,7 +20,6 @@ import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketAddress; -import java.net.SocketException; import java.net.SocketTimeoutException; import java.util.Date; import java.util.concurrent.Executors; @@ -57,7 +56,7 @@ public class MllpTcpClientProducer extends DefaultProducer implements Runnable { private String cachedRemoteAddress; private String cachedCombinedAddress; - public MllpTcpClientProducer(MllpEndpoint endpoint) throws SocketException { + public MllpTcpClientProducer(MllpEndpoint endpoint) { super(endpoint); log = LoggerFactory diff --git a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java index 3d6c3bb..f0eba38 100644 --- a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java +++ b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java @@ -282,7 +282,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint, } } - public static void expectsMessageCount(int count, MockEndpoint... endpoints) throws InterruptedException { + public static void expectsMessageCount(int count, MockEndpoint... endpoints) { for (MockEndpoint endpoint : endpoints) { endpoint.setExpectedMessageCount(count); } diff --git a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/BaseMyBatisEndpoint.java b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/BaseMyBatisEndpoint.java index 466bd5c..4746053 100644 --- a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/BaseMyBatisEndpoint.java +++ b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/BaseMyBatisEndpoint.java @@ -16,8 +16,6 @@ */ package org.apache.camel.component.mybatis; -import java.io.IOException; - import org.apache.camel.Component; import org.apache.camel.spi.UriParam; import org.apache.camel.support.DefaultPollingEndpoint; @@ -44,7 +42,7 @@ public abstract class BaseMyBatisEndpoint extends DefaultPollingEndpoint { return (MyBatisComponent) super.getComponent(); } - public SqlSessionFactory getSqlSessionFactory() throws IOException { + public SqlSessionFactory getSqlSessionFactory() { return getComponent().getSqlSessionFactory(); } diff --git a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisProducer.java b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisProducer.java index 4451ca3..f3e3469 100644 --- a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisProducer.java +++ b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisProducer.java @@ -93,7 +93,7 @@ public class MyBatisProducer extends DefaultProducer { } } - private void doSelectOne(Exchange exchange, SqlSession session) throws Exception { + private void doSelectOne(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { @@ -107,7 +107,7 @@ public class MyBatisProducer extends DefaultProducer { doProcessResult(exchange, result, session); } - private void doSelectList(Exchange exchange, SqlSession session) throws Exception { + private void doSelectList(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { @@ -121,7 +121,7 @@ public class MyBatisProducer extends DefaultProducer { doProcessResult(exchange, result, session); } - private void doInsert(Exchange exchange, SqlSession session) throws Exception { + private void doInsert(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { @@ -140,7 +140,7 @@ public class MyBatisProducer extends DefaultProducer { } } - private void doInsertList(Exchange exchange, SqlSession session) throws Exception { + private void doInsertList(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { @@ -155,7 +155,7 @@ public class MyBatisProducer extends DefaultProducer { } } - private void doUpdate(Exchange exchange, SqlSession session) throws Exception { + private void doUpdate(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { @@ -174,7 +174,7 @@ public class MyBatisProducer extends DefaultProducer { } } - private void doUpdateList(Exchange exchange, SqlSession session) throws Exception { + private void doUpdateList(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { @@ -189,7 +189,7 @@ public class MyBatisProducer extends DefaultProducer { } } - private void doDelete(Exchange exchange, SqlSession session) throws Exception { + private void doDelete(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { @@ -208,7 +208,7 @@ public class MyBatisProducer extends DefaultProducer { } } - private void doDeleteList(Exchange exchange, SqlSession session) throws Exception { + private void doDeleteList(Exchange exchange, SqlSession session) { Object result; Object in = getInput(exchange); if (in != null) { diff --git a/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerProducer.java b/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerProducer.java index f35f3f3..75ebb9d 100644 --- a/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerProducer.java +++ b/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerProducer.java @@ -192,7 +192,7 @@ public class OptaPlannerProducer extends DefaultAsyncProducer { exchange.getIn().setHeader(OptaPlannerConstants.IS_SOLVING, solver.isSolving()); } - private String getSolverId(Exchange exchange) throws Exception { + private String getSolverId(Exchange exchange) { String solverId = exchange.getIn().getHeader(OptaPlannerConstants.SOLVER_ID, String.class); if (solverId == null) { solverId = configuration.getSolverId(); diff --git a/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventProducer.java b/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventProducer.java index 7038a9a..d0a6f9d 100644 --- a/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventProducer.java +++ b/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventProducer.java @@ -30,7 +30,7 @@ public class PgEventProducer extends DefaultProducer { private final PgEventEndpoint endpoint; private PGConnection dbConnection; - public PgEventProducer(PgEventEndpoint endpoint) throws Exception { + public PgEventProducer(PgEventEndpoint endpoint) { super(endpoint); this.endpoint = endpoint; } diff --git a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterConfiguration.java b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterConfiguration.java index 01547fa..c5a6885 100644 --- a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterConfiguration.java +++ b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterConfiguration.java @@ -17,7 +17,6 @@ package org.apache.camel.component.printer; import java.net.URI; -import java.net.URISyntaxException; import java.util.Map; import javax.print.DocFlavor; @@ -70,7 +69,7 @@ public class PrinterConfiguration { public PrinterConfiguration() { } - public PrinterConfiguration(URI uri) throws URISyntaxException { + public PrinterConfiguration(URI uri) { this.uri = uri; } @@ -118,7 +117,7 @@ public class PrinterConfiguration { } } - private DocFlavor assignDocFlavor(String flavor, String mimeType) throws Exception { + private DocFlavor assignDocFlavor(String flavor, String mimeType) { // defaults if (mimeType == null) { mimeType = "AUTOSENSE"; diff --git a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterOperations.java b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterOperations.java index 29487a4..4985ccb 100644 --- a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterOperations.java +++ b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterOperations.java @@ -59,7 +59,7 @@ public class PrinterOperations implements PrinterOperationsInterface { } public PrinterOperations(PrintService printService, DocFlavor flavor, - PrintRequestAttributeSet printRequestAttributeSet) throws PrintException { + PrintRequestAttributeSet printRequestAttributeSet) { this.setPrintService(printService); this.setFlavor(flavor); this.setPrintRequestAttributeSet(printRequestAttributeSet); diff --git a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterProducer.java b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterProducer.java index dcc78bf..27a9ec7 100644 --- a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterProducer.java +++ b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterProducer.java @@ -45,7 +45,7 @@ public class PrinterProducer extends DefaultProducer { private PrintService printService; private String printer; - public PrinterProducer(Endpoint endpoint, PrinterConfiguration config) throws Exception { + public PrinterProducer(Endpoint endpoint, PrinterConfiguration config) { super(endpoint); this.config = config; } @@ -65,7 +65,7 @@ public class PrinterProducer extends DefaultProducer { } } - private DocFlavor assignDocFlavor() throws Exception { + private DocFlavor assignDocFlavor() { return config.getDocFlavor(); } diff --git a/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java b/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java index e32bc8e..3b5ca97 100644 --- a/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java +++ b/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java @@ -548,7 +548,7 @@ public class QuartzEndpoint extends DefaultEndpoint { return result; } - private JobDetail createJobDetail() throws Exception { + private JobDetail createJobDetail() { // Camel endpoint timer will assume one to one for JobDetail and Trigger, so let's use same name as trigger String name = triggerKey.getName(); String group = triggerKey.getGroup(); diff --git a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/CronScheduledRoutePolicy.java b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/CronScheduledRoutePolicy.java index baf8460..03af3bc 100644 --- a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/CronScheduledRoutePolicy.java +++ b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/CronScheduledRoutePolicy.java @@ -44,7 +44,7 @@ public class CronScheduledRoutePolicy extends ScheduledRoutePolicy implements Sc } } - protected void doOnInit(Route route) throws Exception { + protected void doOnInit(Route route) { QuartzComponent quartz = route.getCamelContext().getComponent("quartz", QuartzComponent.class); quartz.addScheduleInitTask(scheduler -> { setScheduler(scheduler); diff --git a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java index a66eaf1..25859a0 100644 --- a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java +++ b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/ScheduledRoutePolicy.java @@ -176,7 +176,7 @@ public abstract class ScheduledRoutePolicy extends RoutePolicySupport LOG.debug("Scheduled job: {} is deleted", jobKey); } - protected JobDetail createJobDetail(Action action, Route route) throws Exception { + protected JobDetail createJobDetail(Action action, Route route) { JobDetail jobDetail = null; if (action == Action.START) { @@ -196,8 +196,7 @@ public abstract class ScheduledRoutePolicy extends RoutePolicySupport return jobDetail; } - protected void updateScheduledRouteDetails(Action action, JobDetail jobDetail, Trigger trigger, Route route) - throws Exception { + protected void updateScheduledRouteDetails(Action action, JobDetail jobDetail, Trigger trigger, Route route) { ScheduledRouteDetails scheduledRouteDetails = getScheduledRouteDetails(route.getId()); if (action == Action.START) { scheduledRouteDetails.setStartJobKey(jobDetail.getKey()); diff --git a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java index 0628900..08b28bc 100644 --- a/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java +++ b/components/camel-quartz/src/main/java/org/apache/camel/routepolicy/quartz/SimpleScheduledRoutePolicy.java @@ -50,7 +50,7 @@ public class SimpleScheduledRoutePolicy extends ScheduledRoutePolicy { } } - protected void doOnInit(Route route) throws Exception { + protected void doOnInit(Route route) { QuartzComponent quartz = route.getCamelContext().getComponent("quartz", QuartzComponent.class); quartz.addScheduleInitTask(scheduler -> { setScheduler(scheduler); diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java index 2f7aa84..c1cb136 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java @@ -31,8 +31,7 @@ public class MessageCorrelator implements QuickfixjEventListener { public static final long DEFAULT_CORRELATION_TIMEOUT = 1000L; private final List<MessageCorrelationRule> rules = new CopyOnWriteArrayList<>(); - public Callable<Message> getReply(SessionID sessionID, Exchange exchange) - throws InterruptedException, ExchangeTimedOutException { + public Callable<Message> getReply(SessionID sessionID, Exchange exchange) { MessagePredicate messageCriteria = (MessagePredicate) exchange.getProperty(QuickfixjProducer.CORRELATION_CRITERIA_KEY); final MessageCorrelationRule correlationRule = new MessageCorrelationRule(exchange, sessionID, messageCriteria); diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java index cf92c6e..318341e 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjComponent.java @@ -141,7 +141,7 @@ public class QuickfixjComponent extends DefaultComponent implements StartupListe super.doShutdown(); } - private void startQuickfixjEngine(QuickfixjEngine engine) throws Exception { + private void startQuickfixjEngine(QuickfixjEngine engine) { if (!engine.isLazy()) { LOG.info("Starting QuickFIX/J engine: {}", engine.getUri()); engine.start(); diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/converter/QuickfixjConverters.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/converter/QuickfixjConverters.java index 35017c8..5850aaf 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/converter/QuickfixjConverters.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/converter/QuickfixjConverters.java @@ -87,7 +87,7 @@ public final class QuickfixjConverters { @Converter public static InputStream toInputStream(Message value, Exchange exchange) - throws InvalidMessage, ConfigError, UnsupportedEncodingException { + throws UnsupportedEncodingException { if (exchange != null) { String charsetName = ExchangeHelper.getCharsetName(exchange); if (charsetName != null) { diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java index 40993a8..3935185 100644 --- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java +++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelSubscription.java @@ -190,7 +190,7 @@ public class CamelSubscription implements Subscription { } } - public void signalCompletion() throws Exception { + public void signalCompletion() { mutex.lock(); terminating = true; mutex.unlock(); diff --git a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducer.java b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducer.java index dfee16c..f25c18b 100644 --- a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducer.java +++ b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestProducer.java @@ -367,8 +367,7 @@ public class RestProducer extends DefaultAsyncProducer { return new RestProducerBindingProcessor(producer, camelContext, json, jaxb, outJson, outJaxb, mode, skip, outType); } - private void setAdditionalConfiguration(RestConfiguration config, String prefix, PropertyBindingSupport.Builder builder) - throws Exception { + private void setAdditionalConfiguration(RestConfiguration config, String prefix, PropertyBindingSupport.Builder builder) { if (config.getDataFormatProperties() != null && !config.getDataFormatProperties().isEmpty()) { // must use a copy as otherwise the options gets removed during introspection setProperties Map<String, Object> copy = new HashMap<>(); diff --git a/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java b/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java index fd7f38a..63493ab 100644 --- a/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java +++ b/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java @@ -438,7 +438,7 @@ public abstract class XQueryBuilder implements Expression, Predicate, NamespaceA return namespacePrefixes; } - public XQueryExpression getExpression() throws IOException, XPathException { + public XQueryExpression getExpression() { return expression; } @@ -666,8 +666,7 @@ public abstract class XQueryBuilder implements Expression, Predicate, NamespaceA /** * Configures the dynamic context with exchange specific parameters */ - protected void configureQuery(DynamicQueryContext dynamicQueryContext, Exchange exchange) - throws Exception { + protected void configureQuery(DynamicQueryContext dynamicQueryContext, Exchange exchange) { addParameters(dynamicQueryContext, exchange.getProperties()); addParameters(dynamicQueryContext, exchange.getIn().getHeaders(), "in.headers."); dynamicQueryContext.setParameter( diff --git a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java index 80b8cd2..01b39ef 100644 --- a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java +++ b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java @@ -219,7 +219,7 @@ public class SedaEndpoint extends DefaultEndpoint implements AsyncEndpoint, Brow return ref; } - protected synchronized AsyncProcessor getConsumerMulticastProcessor() throws Exception { + protected synchronized AsyncProcessor getConsumerMulticastProcessor() { if (!multicastStarted && consumerMulticastProcessor != null) { // only start it on-demand to avoid starting it during stopping ServiceHelper.startService(consumerMulticastProcessor); diff --git a/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/AbstractServiceNowProcessor.java b/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/AbstractServiceNowProcessor.java index d63f44f..a4d4007 100644 --- a/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/AbstractServiceNowProcessor.java +++ b/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/AbstractServiceNowProcessor.java @@ -45,7 +45,7 @@ public abstract class AbstractServiceNowProcessor implements Processor { private final JavaTypeCache javaTypeCache; private final List<ServiceNowDispatcher> dispatchers; - protected AbstractServiceNowProcessor(ServiceNowEndpoint endpoint) throws Exception { + protected AbstractServiceNowProcessor(ServiceNowEndpoint endpoint) { this.javaTypeCache = new JavaTypeCache(); this.endpoint = endpoint; this.config = endpoint.getConfiguration(); diff --git a/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java b/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java index 182c3d3..9aa2d5b 100644 --- a/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java +++ b/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java @@ -44,7 +44,7 @@ public class ServiceNowEndpoint extends DefaultEndpoint { private final ServiceNowConfiguration configuration; public ServiceNowEndpoint(String uri, ServiceNowComponent component, ServiceNowConfiguration configuration, - String instanceName) throws Exception { + String instanceName) { super(uri, component); this.configuration = configuration; diff --git a/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipConfiguration.java b/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipConfiguration.java index 350c96a..f7caaf2 100644 --- a/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipConfiguration.java +++ b/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipConfiguration.java @@ -376,7 +376,7 @@ public class SipConfiguration { setContentTypeHeader(headerFactory.createContentTypeHeader(getContentType(), getContentSubType())); } - private void createMaxForwardsHeader() throws ParseException, InvalidArgumentException { + private void createMaxForwardsHeader() throws InvalidArgumentException { setMaxForwardsHeader(headerFactory.createMaxForwardsHeader(getMaxForwards())); } @@ -397,7 +397,7 @@ public class SipConfiguration { contactHeader = headerFactory.createContactHeader(contactAddress); } - private void createExpiresHeader() throws ParseException, InvalidArgumentException { + private void createExpiresHeader() throws InvalidArgumentException { expiresHeader = getHeaderFactory().createExpiresHeader(getMsgExpiration()); } diff --git a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java index 4887f4f..bc4f88c 100644 --- a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java +++ b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java @@ -70,7 +70,7 @@ public class SmppComponent extends DefaultComponent { /** * Create a new smpp endpoint with the provided uri and smpp configuration */ - protected Endpoint createEndpoint(String uri, SmppConfiguration config) throws Exception { + protected Endpoint createEndpoint(String uri, SmppConfiguration config) { return new SmppEndpoint(uri, this, config); } diff --git a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java index b5a53d6..f076735 100644 --- a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java +++ b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelTargetAdapter.java @@ -46,7 +46,7 @@ public class CamelTargetAdapter extends AbstractCamelAdapter implements MessageH return replyChannel; } - public ProducerTemplate getCamelTemplate() throws Exception { + public ProducerTemplate getCamelTemplate() { if (camelTemplate == null) { CamelContext ctx = getCamelContext(); if (ctx == null) { diff --git a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/converter/SpringIntegrationConverter.java b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/converter/SpringIntegrationConverter.java index c86e2c8..dd657f0 100644 --- a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/converter/SpringIntegrationConverter.java +++ b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/converter/SpringIntegrationConverter.java @@ -37,14 +37,13 @@ public final class SpringIntegrationConverter { } @Converter - public static Endpoint toEndpoint(final MessageChannel channel) throws Exception { + public static Endpoint toEndpoint(final MessageChannel channel) { Endpoint answer = new SpringIntegrationEndpoint("spring-integration://" + channel.toString(), channel.toString(), null); return answer; } @Converter - public static org.springframework.messaging.Message<?> toSpringMessage(final org.apache.camel.Message camelMessage) - throws Exception { + public static org.springframework.messaging.Message<?> toSpringMessage(final org.apache.camel.Message camelMessage) { if (camelMessage instanceof SpringIntegrationMessage) { SpringIntegrationMessage siMessage = (SpringIntegrationMessage) camelMessage; org.springframework.messaging.Message<?> message = siMessage.getMessage(); @@ -59,8 +58,7 @@ public final class SpringIntegrationConverter { } @Converter - public static org.apache.camel.Message toCamelMessage(final org.springframework.messaging.Message<?> springMessage) - throws Exception { + public static org.apache.camel.Message toCamelMessage(final org.springframework.messaging.Message<?> springMessage) { return new SpringIntegrationMessage((CamelContext) null, springMessage); } diff --git a/components/camel-spring-javaconfig/src/main/java/org/apache/camel/spring/javaconfig/CamelConfiguration.java b/components/camel-spring-javaconfig/src/main/java/org/apache/camel/spring/javaconfig/CamelConfiguration.java index 435d07c..2e61b0c 100644 --- a/components/camel-spring-javaconfig/src/main/java/org/apache/camel/spring/javaconfig/CamelConfiguration.java +++ b/components/camel-spring-javaconfig/src/main/java/org/apache/camel/spring/javaconfig/CamelConfiguration.java @@ -130,7 +130,7 @@ public abstract class CamelConfiguration implements BeanFactoryAware, Applicatio */ @Bean(initMethod = "", destroyMethod = "") // Camel handles the lifecycle of this bean - public ProducerTemplate producerTemplate(CamelContext camelContext) throws Exception { + public ProducerTemplate producerTemplate(CamelContext camelContext) { return camelContext.createProducerTemplate(); } @@ -139,7 +139,7 @@ public abstract class CamelConfiguration implements BeanFactoryAware, Applicatio */ @Bean(initMethod = "", destroyMethod = "") // Camel handles the lifecycle of this bean - public ConsumerTemplate consumerTemplate(CamelContext camelContext) throws Exception { + public ConsumerTemplate consumerTemplate(CamelContext camelContext) { return camelContext.createConsumerTemplate(); } @@ -183,7 +183,7 @@ public abstract class CamelConfiguration implements BeanFactoryAware, Applicatio * @return {@link CamelContext} used by this configuration. By default {@link SpringCamelContext} instance is * created, to fully integrate Spring application context and Camel registry. */ - protected CamelContext createCamelContext() throws Exception { + protected CamelContext createCamelContext() { return new SpringCamelContext(getApplicationContext()); } diff --git a/components/camel-spring-main/src/main/java/org/apache/camel/spring/Main.java b/components/camel-spring-main/src/main/java/org/apache/camel/spring/Main.java index b1eb09b..aa386c7 100644 --- a/components/camel-spring-main/src/main/java/org/apache/camel/spring/Main.java +++ b/components/camel-spring-main/src/main/java/org/apache/camel/spring/Main.java @@ -229,7 +229,7 @@ public class Main extends MainCommandLineSupport { return getCamelContext().createProducerTemplate(); } - protected AbstractApplicationContext createDefaultApplicationContext() throws IOException { + protected AbstractApplicationContext createDefaultApplicationContext() { ApplicationContext parentContext = getParentApplicationContext(); // file based diff --git a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQEndpoint.java b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQEndpoint.java index b460b71..e60f89b 100644 --- a/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQEndpoint.java +++ b/components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/SpringRabbitMQEndpoint.java @@ -531,7 +531,7 @@ public class SpringRabbitMQEndpoint extends DefaultEndpoint implements AsyncEndp return new AsyncRabbitTemplate(template); } - public AbstractMessageListenerContainer createMessageListenerContainer() throws Exception { + public AbstractMessageListenerContainer createMessageListenerContainer() { return getComponent().getListenerContainerFactory().createListenerContainer(this); } diff --git a/components/camel-spring-xml/src/main/java/org/apache/camel/spring/xml/PackageScanRouteBuilderFinder.java b/components/camel-spring-xml/src/main/java/org/apache/camel/spring/xml/PackageScanRouteBuilderFinder.java index 5d5e874..6416ad3 100644 --- a/components/camel-spring-xml/src/main/java/org/apache/camel/spring/xml/PackageScanRouteBuilderFinder.java +++ b/components/camel-spring-xml/src/main/java/org/apache/camel/spring/xml/PackageScanRouteBuilderFinder.java @@ -54,7 +54,7 @@ public class PackageScanRouteBuilderFinder { /** * Appends all the {@link org.apache.camel.builder.RouteBuilder} instances that can be found on the classpath */ - public void appendBuilders(List<RoutesBuilder> list) throws IllegalAccessException, InstantiationException { + public void appendBuilders(List<RoutesBuilder> list) { Set<Class<?>> classes = resolver.findImplementations(RoutesBuilder.class, packages); for (Class<?> aClass : classes) { LOG.trace("Found RouteBuilder class: {}", aClass); @@ -108,8 +108,7 @@ public class PackageScanRouteBuilderFinder { return false; } - protected RoutesBuilder instantiateBuilder(Class<? extends RoutesBuilder> type) - throws IllegalAccessException, InstantiationException { + protected RoutesBuilder instantiateBuilder(Class<? extends RoutesBuilder> type) { return camelContext.getInjector().newInstance(type); } } diff --git a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java index 775e5eb..3f1f18a 100644 --- a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java +++ b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamProducer.java @@ -94,7 +94,7 @@ public class StreamProducer extends DefaultProducer { return new FileOutputStream(f, true); } - private OutputStream resolveStreamFromHeader(Object o, Exchange exchange) throws CamelExchangeException { + private OutputStream resolveStreamFromHeader(Object o, Exchange exchange) { return exchange.getContext().getTypeConverter().convertTo(OutputStream.class, o); } diff --git a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java index f8118cb..3302739 100644 --- a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java +++ b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java @@ -40,7 +40,7 @@ public class ThriftEndpoint extends DefaultEndpoint { private String serviceName; private String servicePackage; - public ThriftEndpoint(String uri, ThriftComponent component, ThriftConfiguration config) throws Exception { + public ThriftEndpoint(String uri, ThriftComponent component, ThriftConfiguration config) { super(uri, component); this.configuration = config; diff --git a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftProducer.java b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftProducer.java index 617ee00..c5aaebe 100644 --- a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftProducer.java +++ b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftProducer.java @@ -152,7 +152,7 @@ public class ThriftProducer extends DefaultAsyncProducer implements AsyncProduce syncTransport.open(); } - protected void initializeAsyncTransport() throws IOException, TTransportException { + protected void initializeAsyncTransport() throws IOException { if (!ObjectHelper.isEmpty(configuration.getHost()) && !ObjectHelper.isEmpty(configuration.getPort())) { LOG.info("Creating transport to the remote Thrift server {}:{}", configuration.getHost(), configuration.getPort()); asyncTransport = new TNonblockingSocket(configuration.getHost(), configuration.getPort()); diff --git a/components/camel-thrift/src/main/java/org/apache/camel/dataformat/thrift/ThriftDataFormat.java b/components/camel-thrift/src/main/java/org/apache/camel/dataformat/thrift/ThriftDataFormat.java index 5d774e2..052e600 100644 --- a/components/camel-thrift/src/main/java/org/apache/camel/dataformat/thrift/ThriftDataFormat.java +++ b/components/camel-thrift/src/main/java/org/apache/camel/dataformat/thrift/ThriftDataFormat.java @@ -100,7 +100,7 @@ public class ThriftDataFormat extends ServiceSupport } } - public void setInstanceClass(String className) throws Exception { + public void setInstanceClass(String className) { ObjectHelper.notNull(className, "ThriftDataFormat instaceClass"); instanceClassName = className; } diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java index 13fa53b..e3f7738 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java @@ -469,7 +469,7 @@ public class WebsocketComponent extends DefaultComponent implements SSLContextPa return servlet; } - protected ServletContextHandler createContext(Server server, Connector connector, List<Handler> handlers) throws Exception { + protected ServletContextHandler createContext(Server server, Connector connector, List<Handler> handlers) { ServletContextHandler context = new ServletContextHandler(server, "/", ServletContextHandler.NO_SECURITY | ServletContextHandler.NO_SESSIONS); server.addConnector(connector); diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java index c13adf4..63bc0b5 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketProducer.java @@ -16,7 +16,6 @@ */ package org.apache.camel.component.websocket; -import java.io.IOException; import java.nio.ByteBuffer; import java.util.Collection; import java.util.List; @@ -160,7 +159,7 @@ public class WebsocketProducer extends DefaultProducer implements WebsocketProdu } } - Future<Void> sendMessage(DefaultWebsocket websocket, Object message) throws IOException { + Future<Void> sendMessage(DefaultWebsocket websocket, Object message) { Future<Void> future = null; // in case there is web socket and socket connection is open - send message if (websocket != null && websocket.getSession().isOpen()) { diff --git a/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaProducer.java b/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaProducer.java index e0de1d1..94b3df3 100644 --- a/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaProducer.java +++ b/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaProducer.java @@ -103,7 +103,7 @@ public class WekaProducer extends DefaultProducer { } } - Dataset handlePushCmd(Exchange exchange) throws Exception { + Dataset handlePushCmd(Exchange exchange) { String dsname = getConfiguration().getDsname(); @@ -117,7 +117,7 @@ public class WekaProducer extends DefaultProducer { return dataset; } - Dataset handlePopCmd(Exchange exchange) throws Exception { + Dataset handlePopCmd(Exchange exchange) { String dsname = getConfiguration().getDsname(); @@ -131,7 +131,7 @@ public class WekaProducer extends DefaultProducer { return dataset; } - Dataset handleReadCmd(Exchange exchange) throws Exception { + Dataset handleReadCmd(Exchange exchange) { String fpath = getConfiguration().getPath(); @@ -144,7 +144,7 @@ public class WekaProducer extends DefaultProducer { return dataset; } - Object handleWriteCmd(Exchange exchange) throws Exception { + Object handleWriteCmd(Exchange exchange) { Dataset dataset = assertDatasetBody(exchange); String fpath = getConfiguration().getPath(); @@ -168,7 +168,7 @@ public class WekaProducer extends DefaultProducer { } } - Dataset handleFilterCmd(Exchange exchange) throws Exception { + Dataset handleFilterCmd(Exchange exchange) { String applyValue = getConfiguration().getApply(); @@ -178,7 +178,7 @@ public class WekaProducer extends DefaultProducer { return dataset; } - Dataset handleModelCmd(Exchange exchange) throws Exception { + Dataset handleModelCmd(Exchange exchange) { Dataset dataset = assertDatasetBody(exchange); @@ -244,7 +244,7 @@ public class WekaProducer extends DefaultProducer { return dataset; } - private Dataset assertDatasetBody(Exchange exchange) throws Exception { + private Dataset assertDatasetBody(Exchange exchange) { Message msg = exchange.getMessage(); Dataset dataset = msg.getBody(Dataset.class); diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java index 29b1811..f9468a6 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppConsumer.java @@ -119,7 +119,7 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage super.doStart(); } - protected void scheduleDelayedStart() throws Exception { + protected void scheduleDelayedStart() { Runnable startRunnable = new Runnable() { @Override public void run() { @@ -135,7 +135,7 @@ public class XmppConsumer extends DefaultConsumer implements IncomingChatMessage getExecutor().schedule(startRunnable, endpoint.getConnectionPollDelay(), TimeUnit.SECONDS); } - private void startRobustConnectionMonitor() throws Exception { + private void startRobustConnectionMonitor() { Runnable connectionCheckRunnable = new Runnable() { @Override public void run() { diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java index e2f6cf0..779074d 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java @@ -134,15 +134,15 @@ public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrateg return new XmppGroupChatProducer(this); } - public Producer createPrivateChatProducer(String participant) throws Exception { + public Producer createPrivateChatProducer(String participant) { return new XmppPrivateChatProducer(this, participant); } - public Producer createDirectProducer() throws Exception { + public Producer createDirectProducer() { return new XmppDirectProducer(this); } - public Producer createPubSubProducer() throws Exception { + public Producer createPubSubProducer() { return new XmppPubSubProducer(this); } diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java index 65e8e90..3e85603 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppGroupChatProducer.java @@ -41,7 +41,7 @@ public class XmppGroupChatProducer extends DefaultProducer { private MultiUserChat chat; private String room; - public XmppGroupChatProducer(XmppEndpoint endpoint) throws XMPPException { + public XmppGroupChatProducer(XmppEndpoint endpoint) { super(endpoint); this.endpoint = endpoint; }