You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/06/23 14:35:31 UTC
[camel] branch main updated: (chores) Cleanup unused throws (#5743)
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 <or...@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;
}