You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/03/10 14:52:27 UTC
[camel] branch main updated (b9a5d21 -> 672262d)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
from b9a5d21 CAMEL-17773: http components using toD fix when contet-path is empty. Thanks to Artem St for unit tests.
new 3de7b64 CAMEL-17763: cleaned up unused exceptions in camel-sjms2
new 672262d CAMEL-17763: cleaned up unused exceptions in camel-sjms
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../component/sjms/AsyncStartStopListenerTest.java | 4 ++--
.../component/sjms/JmsMessageTimestampTest.java | 4 ++--
.../component/sjms/JmsSelectorOptionTest.java | 4 ++--
.../camel/component/sjms/JmsSelectorTest.java | 4 ++--
.../component/sjms/ReconnectConsumerTest.java | 4 ++--
.../component/sjms/ReconnectInOutProducerTest.java | 2 +-
.../component/sjms/ReconnectProducerTest.java | 5 ++---
.../component/sjms/SimpleJmsComponentTest.java | 4 ++--
.../component/sjms/SjmsComponentRestartTest.java | 4 ++--
.../sjms/SjmsEndpointConnectionSettingsTest.java | 2 +-
.../sjms/SjmsEndpointNameOverrideTest.java | 6 +++---
.../camel/component/sjms/SjmsEndpointTest.java | 24 +++++++++++-----------
.../component/sjms/bugfixes/CAMEL6820Test.java | 4 ++--
.../sjms/consumer/AsyncConsumerFalseTest.java | 4 ++--
.../sjms/consumer/AsyncConsumerInOutTest.java | 4 ++--
.../consumer/AutowiredConnectionFactoryTest.java | 4 ++--
.../sjms/consumer/EmptyMessageBodyTest.java | 4 ++--
.../consumer/InOnlyConsumerAsyncFalseTest.java | 6 +++---
.../sjms/consumer/InOnlyConsumerDefaultTest.java | 4 ++--
.../InOnlyConsumerQueueSynchronousTest.java | 4 ++--
.../sjms/consumer/InOnlyConsumerQueueTest.java | 4 ++--
.../sjms/consumer/InOnlyConsumerTempQueueTest.java | 4 ++--
.../sjms/consumer/InOnlyConsumerTopicTest.java | 4 ++--
.../sjms/consumer/InOnlyPooledExchangeTest.java | 4 ++--
.../sjms/consumer/InOnlyQueueConsumerTest.java | 5 ++---
.../sjms/consumer/InOnlyTopicConsumerTest.java | 5 ++---
.../consumer/InOnlyTopicDurableConsumerTest.java | 4 ++--
.../sjms/consumer/InOutConcurrentConsumerTest.java | 4 ++--
.../sjms/consumer/InOutConsumerQueueAsyncTest.java | 4 ++--
.../sjms/consumer/InOutConsumerQueueTest.java | 4 ++--
.../consumer/InOutConsumerTempQueueAsyncTest.java | 4 ++--
.../sjms/consumer/InOutConsumerTempQueueTest.java | 4 ++--
.../sjms/consumer/InOutConsumerTopicTest.java | 4 ++--
.../consumer/InOutSynchronousConsumerTest.java | 6 +++---
.../sjms/consumer/JmsPollingConsumerTest.java | 4 ++--
.../camel/component/sjms/it/AsyncJmsInOutIT.java | 4 ++--
.../component/sjms/it/AsyncJmsInOutTempDestIT.java | 4 ++--
.../camel/component/sjms/it/SyncJmsInOutIT.java | 4 ++--
.../component/sjms/it/SyncJmsInOutTempDestIT.java | 4 ++--
.../sjms/jms/DestinationNameParserTest.java | 8 ++++----
.../component/sjms/manual/ManualFromQueueTest.java | 4 ++--
.../sjms/producer/AsyncQueueProducerTest.java | 10 ++++-----
.../sjms/producer/AsyncTopicProducerTest.java | 10 ++++-----
.../sjms/producer/InOnlyQueueProducerTest.java | 2 +-
.../sjms/producer/InOnlyTopicProducerTest.java | 5 ++---
.../producer/InOutQueueProducerAsyncLoadTest.java | 2 +-
.../producer/InOutQueueProducerSyncLoadTest.java | 4 ++--
.../sjms/producer/InOutQueueProducerTest.java | 2 +-
.../sjms/producer/QueueProducerQoSTest.java | 4 ++--
.../component/sjms/producer/QueueProducerTest.java | 2 +-
.../sjms/producer/SjmsToDSendDynamicTest.java | 6 +++---
.../SjmsToDSendDynamicTwoDisabledTest.java | 6 +++---
.../sjms/producer/SjmsToDSendDynamicTwoTest.java | 6 +++---
.../camel/component/sjms/producer/SjmsToDTest.java | 4 ++--
.../component/sjms/support/MyAsyncEndpoint.java | 4 ++--
.../sjms/support/SjmsConnectionTestSupport.java | 4 ++--
.../component/sjms/threadpool/ThreadPoolTest.java | 4 ++--
.../sjms/tx/TransactedAsyncExceptionTest.java | 2 +-
.../sjms/tx/TransactedConsumerSupport.java | 4 ++--
.../sjms/tx/TransactedOnCompletionTest.java | 2 +-
.../sjms/tx/TransactedProducerInOutErrorTest.java | 4 ++--
.../sjms/tx/TransactedQueueInOutProducerTest.java | 2 +-
.../sjms/tx/TransactedQueueProducerTest.java | 2 +-
.../sjms/tx/TransactedTopicProducerTest.java | 2 +-
.../component/sjms2/SimpleJms2ComponentTest.java | 4 ++--
.../component/sjms2/Sjms2ComponentRestartTest.java | 4 ++--
.../sjms2/Sjms2EndpointNameOverrideTest.java | 6 +++---
.../camel/component/sjms2/Sjms2EndpointTest.java | 22 ++++++++++----------
.../consumer/InOnlyTopicDurableConsumerTest.java | 4 ++--
.../consumer/InOnlyTopicSharedConsumerTest.java | 2 +-
.../sjms2/producer/InOnlyQueueProducerTest.java | 2 +-
.../sjms2/producer/InOnlyTopicProducerTest.java | 5 ++---
.../sjms2/producer/Sjms2ToDSendDynamicTest.java | 6 +++---
73 files changed, 168 insertions(+), 173 deletions(-)
[camel] 02/02: CAMEL-17763: cleaned up unused exceptions in camel-sjms
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 672262d4a38a0a87c8c3be69a65c0b89174637c2
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Mar 10 14:59:40 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-sjms
---
.../component/sjms/AsyncStartStopListenerTest.java | 4 ++--
.../component/sjms/JmsMessageTimestampTest.java | 4 ++--
.../component/sjms/JmsSelectorOptionTest.java | 4 ++--
.../camel/component/sjms/JmsSelectorTest.java | 4 ++--
.../component/sjms/ReconnectConsumerTest.java | 4 ++--
.../component/sjms/ReconnectInOutProducerTest.java | 2 +-
.../component/sjms/ReconnectProducerTest.java | 5 ++---
.../component/sjms/SimpleJmsComponentTest.java | 4 ++--
.../component/sjms/SjmsComponentRestartTest.java | 4 ++--
.../sjms/SjmsEndpointConnectionSettingsTest.java | 2 +-
.../sjms/SjmsEndpointNameOverrideTest.java | 6 +++---
.../camel/component/sjms/SjmsEndpointTest.java | 24 +++++++++++-----------
.../component/sjms/bugfixes/CAMEL6820Test.java | 4 ++--
.../sjms/consumer/AsyncConsumerFalseTest.java | 4 ++--
.../sjms/consumer/AsyncConsumerInOutTest.java | 4 ++--
.../consumer/AutowiredConnectionFactoryTest.java | 4 ++--
.../sjms/consumer/EmptyMessageBodyTest.java | 4 ++--
.../consumer/InOnlyConsumerAsyncFalseTest.java | 6 +++---
.../sjms/consumer/InOnlyConsumerDefaultTest.java | 4 ++--
.../InOnlyConsumerQueueSynchronousTest.java | 4 ++--
.../sjms/consumer/InOnlyConsumerQueueTest.java | 4 ++--
.../sjms/consumer/InOnlyConsumerTempQueueTest.java | 4 ++--
.../sjms/consumer/InOnlyConsumerTopicTest.java | 4 ++--
.../sjms/consumer/InOnlyPooledExchangeTest.java | 4 ++--
.../sjms/consumer/InOnlyQueueConsumerTest.java | 5 ++---
.../sjms/consumer/InOnlyTopicConsumerTest.java | 5 ++---
.../consumer/InOnlyTopicDurableConsumerTest.java | 4 ++--
.../sjms/consumer/InOutConcurrentConsumerTest.java | 4 ++--
.../sjms/consumer/InOutConsumerQueueAsyncTest.java | 4 ++--
.../sjms/consumer/InOutConsumerQueueTest.java | 4 ++--
.../consumer/InOutConsumerTempQueueAsyncTest.java | 4 ++--
.../sjms/consumer/InOutConsumerTempQueueTest.java | 4 ++--
.../sjms/consumer/InOutConsumerTopicTest.java | 4 ++--
.../consumer/InOutSynchronousConsumerTest.java | 6 +++---
.../sjms/consumer/JmsPollingConsumerTest.java | 4 ++--
.../camel/component/sjms/it/AsyncJmsInOutIT.java | 4 ++--
.../component/sjms/it/AsyncJmsInOutTempDestIT.java | 4 ++--
.../camel/component/sjms/it/SyncJmsInOutIT.java | 4 ++--
.../component/sjms/it/SyncJmsInOutTempDestIT.java | 4 ++--
.../sjms/jms/DestinationNameParserTest.java | 8 ++++----
.../component/sjms/manual/ManualFromQueueTest.java | 4 ++--
.../sjms/producer/AsyncQueueProducerTest.java | 10 ++++-----
.../sjms/producer/AsyncTopicProducerTest.java | 10 ++++-----
.../sjms/producer/InOnlyQueueProducerTest.java | 2 +-
.../sjms/producer/InOnlyTopicProducerTest.java | 5 ++---
.../producer/InOutQueueProducerAsyncLoadTest.java | 2 +-
.../producer/InOutQueueProducerSyncLoadTest.java | 4 ++--
.../sjms/producer/InOutQueueProducerTest.java | 2 +-
.../sjms/producer/QueueProducerQoSTest.java | 4 ++--
.../component/sjms/producer/QueueProducerTest.java | 2 +-
.../sjms/producer/SjmsToDSendDynamicTest.java | 6 +++---
.../SjmsToDSendDynamicTwoDisabledTest.java | 6 +++---
.../sjms/producer/SjmsToDSendDynamicTwoTest.java | 6 +++---
.../camel/component/sjms/producer/SjmsToDTest.java | 4 ++--
.../component/sjms/support/MyAsyncEndpoint.java | 4 ++--
.../sjms/support/SjmsConnectionTestSupport.java | 4 ++--
.../component/sjms/threadpool/ThreadPoolTest.java | 4 ++--
.../sjms/tx/TransactedAsyncExceptionTest.java | 2 +-
.../sjms/tx/TransactedConsumerSupport.java | 4 ++--
.../sjms/tx/TransactedOnCompletionTest.java | 2 +-
.../sjms/tx/TransactedProducerInOutErrorTest.java | 4 ++--
.../sjms/tx/TransactedQueueInOutProducerTest.java | 2 +-
.../sjms/tx/TransactedQueueProducerTest.java | 2 +-
.../sjms/tx/TransactedTopicProducerTest.java | 2 +-
64 files changed, 141 insertions(+), 145 deletions(-)
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java
index f8d87ba..7d9b3e6 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java
@@ -67,9 +67,9 @@ public class AsyncStartStopListenerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:foo.startstop?asyncStartListener=true&asyncStopListener=true").to("mock:result");
from("sjms:queue:foo.start?asyncStartListener=true").to("mock:result");
from("sjms:queue:foo.stop?asyncStopListener=true").to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsMessageTimestampTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsMessageTimestampTest.java
index a249ca5..66a49b9 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsMessageTimestampTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsMessageTimestampTest.java
@@ -36,9 +36,9 @@ public class JmsMessageTimestampTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:hello").to("mock:result");
}
};
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorOptionTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorOptionTest.java
index 1886c74..daa2750 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorOptionTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorOptionTest.java
@@ -64,9 +64,9 @@ public class JmsSelectorOptionTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:hello?messageSelector=color='blue'").to("mock:a");
from("sjms:queue:hello?messageSelector=color='red'").to("mock:b");
from("sjms:queue:hello?messageSelector=SIZE_NUMBER>1500").to("mock:c");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorTest.java
index d390cbc..cf27f32 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/JmsSelectorTest.java
@@ -44,9 +44,9 @@ public class JmsSelectorTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:test.a").to("log:test-before?showAll=true").to("sjms:test.b");
from("sjms:test.b?messageSelector=cheese='y'").to("log:test-after?showAll=true").to("mock:result");
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectConsumerTest.java
index ebfde3e..e8669d8 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectConsumerTest.java
@@ -46,10 +46,10 @@ public class ReconnectConsumerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME).to(MOCK_RESULT);
}
};
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectInOutProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectInOutProducerTest.java
index 5739243..3184834 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectInOutProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectInOutProducerTest.java
@@ -72,7 +72,7 @@ public class ReconnectInOutProducerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectProducerTest.java
index 7c83ccc..1e8941e 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/ReconnectProducerTest.java
@@ -81,11 +81,10 @@ public class ReconnectProducerTest extends JmsTestSupport {
/**
* @return
- * @throws Exception
- * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
+ * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
*/
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
index b36c3e9..499962f 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
@@ -26,13 +26,13 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class SimpleJmsComponentTest extends CamelTestSupport {
@Test
- public void testHelloWorld() throws Exception {
+ public void testHelloWorld() {
SjmsComponent component = context.getComponent("sjms", SjmsComponent.class);
assertNotNull(component);
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
ActiveMQConnectionFactory connectionFactory
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsComponentRestartTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsComponentRestartTest.java
index 28ddb49..9c4b25d 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsComponentRestartTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsComponentRestartTest.java
@@ -42,7 +42,7 @@ public class SjmsComponentRestartTest extends CamelTestSupport {
public void testRestartWithStopStart() throws Exception {
RouteBuilder routeBuilder = new RouteBuilder(context) {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:test").to("mock:test");
}
};
@@ -78,7 +78,7 @@ public class SjmsComponentRestartTest extends CamelTestSupport {
public void testRestartWithSuspendResume() throws Exception {
RouteBuilder routeBuilder = new RouteBuilder(context) {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:test").to("mock:test");
}
};
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointConnectionSettingsTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointConnectionSettingsTest.java
index 2f4aa3d..9b2a67b 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointConnectionSettingsTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointConnectionSettingsTest.java
@@ -42,7 +42,7 @@ public class SjmsEndpointConnectionSettingsTest extends CamelTestSupport {
}
@Override
- protected CamelContext createCamelContext() throws Exception {
+ protected CamelContext createCamelContext() {
SimpleRegistry registry = new SimpleRegistry();
registry.bind("activemq", connectionFactory);
return new DefaultCamelContext(registry);
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointNameOverrideTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointNameOverrideTest.java
index 9d64033..8f67d6a 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointNameOverrideTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointNameOverrideTest.java
@@ -37,7 +37,7 @@ public class SjmsEndpointNameOverrideTest extends CamelTestSupport {
}
@Test
- public void testDefaults() throws Exception {
+ public void testDefaults() {
Endpoint endpoint = context.getEndpoint(BEAN_NAME + ":test");
assertNotNull(endpoint);
assertTrue(endpoint instanceof SjmsEndpoint);
@@ -47,7 +47,7 @@ public class SjmsEndpointNameOverrideTest extends CamelTestSupport {
}
@Test
- public void testQueueEndpoint() throws Exception {
+ public void testQueueEndpoint() {
Endpoint sjms = context.getEndpoint(BEAN_NAME + ":queue:test");
assertNotNull(sjms);
assertTrue(sjms instanceof SjmsEndpoint);
@@ -55,7 +55,7 @@ public class SjmsEndpointNameOverrideTest extends CamelTestSupport {
}
@Test
- public void testTopicEndpoint() throws Exception {
+ public void testTopicEndpoint() {
Endpoint sjms = context.getEndpoint(BEAN_NAME + ":topic:test");
assertNotNull(sjms);
assertTrue(sjms instanceof SjmsEndpoint);
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointTest.java
index 2d2824c..06c77f9 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SjmsEndpointTest.java
@@ -39,7 +39,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testDefaults() throws Exception {
+ public void testDefaults() {
Endpoint endpoint = context.getEndpoint("sjms:test");
assertNotNull(endpoint);
assertTrue(endpoint instanceof SjmsEndpoint);
@@ -49,7 +49,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testQueueEndpoint() throws Exception {
+ public void testQueueEndpoint() {
Endpoint sjms = context.getEndpoint("sjms:queue:test");
assertNotNull(sjms);
assertEquals("sjms://queue:test", sjms.getEndpointUri());
@@ -57,7 +57,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testJndiStyleEndpointName() throws Exception {
+ public void testJndiStyleEndpointName() {
SjmsEndpoint sjms = context.getEndpoint("sjms:/jms/test/hov.t1.dev:topic", SjmsEndpoint.class);
assertNotNull(sjms);
assertFalse(sjms.isTopic());
@@ -65,7 +65,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testSetTransacted() throws Exception {
+ public void testSetTransacted() {
Endpoint endpoint = context.getEndpoint("sjms:queue:test?transacted=true");
assertNotNull(endpoint);
assertTrue(endpoint instanceof SjmsEndpoint);
@@ -74,7 +74,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testAsyncProducer() throws Exception {
+ public void testAsyncProducer() {
Endpoint endpoint = context.getEndpoint("sjms:queue:test?synchronous=true");
assertNotNull(endpoint);
assertTrue(endpoint instanceof SjmsEndpoint);
@@ -83,7 +83,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testReplyTo() throws Exception {
+ public void testReplyTo() {
String replyTo = "reply.to.queue";
Endpoint endpoint = context.getEndpoint("sjms:queue:test?replyTo=" + replyTo);
assertNotNull(endpoint);
@@ -94,7 +94,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testDefaultExchangePattern() throws Exception {
+ public void testDefaultExchangePattern() {
try {
SjmsEndpoint sjms = (SjmsEndpoint) context.getEndpoint("sjms:queue:test");
assertNotNull(sjms);
@@ -106,7 +106,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testInOnlyExchangePattern() throws Exception {
+ public void testInOnlyExchangePattern() {
try {
Endpoint sjms = context.getEndpoint("sjms:queue:test?exchangePattern=" + ExchangePattern.InOnly);
assertNotNull(sjms);
@@ -117,7 +117,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testInOutExchangePattern() throws Exception {
+ public void testInOutExchangePattern() {
try {
Endpoint sjms = context.getEndpoint("sjms:queue:test?exchangePattern=" + ExchangePattern.InOut);
assertNotNull(sjms);
@@ -128,13 +128,13 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testUnsupportedMessageExchangePattern() throws Exception {
+ public void testUnsupportedMessageExchangePattern() {
assertThrows(ResolveEndpointFailedException.class,
() -> context.getEndpoint("sjms:queue:test2?messageExchangePattern=OutOnly"));
}
@Test
- public void testReplyToAndMEPMatch() throws Exception {
+ public void testReplyToAndMEPMatch() {
String replyTo = "reply.to.queue";
Endpoint endpoint = context
.getEndpoint("sjms:queue:test?replyTo=" + replyTo + "&exchangePattern=" + ExchangePattern.InOut);
@@ -146,7 +146,7 @@ public class SjmsEndpointTest extends CamelTestSupport {
}
@Test
- public void testDestinationName() throws Exception {
+ public void testDestinationName() {
Endpoint endpoint = context.getEndpoint("sjms:queue:test?synchronous=true");
assertNotNull(endpoint);
assertTrue(endpoint instanceof SjmsEndpoint);
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/bugfixes/CAMEL6820Test.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/bugfixes/CAMEL6820Test.java
index 6bcd6e3..40881ea 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/bugfixes/CAMEL6820Test.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/bugfixes/CAMEL6820Test.java
@@ -74,9 +74,9 @@ public class CAMEL6820Test extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(FILE_INPUT_URI)
.convertBodyTo(InputStream.class)
.to(SJMS_QUEUE_URI);
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
index a8917cd..573ca8d 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
@@ -55,10 +55,10 @@ public class AsyncConsumerFalseTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// disable async in only mode on the consumer
from("sjms:queue:start")
.choice()
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
index 0192df4..1983ee9 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
@@ -60,10 +60,10 @@ public class AsyncConsumerInOutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// enable async in only mode on the consumer
from("sjms:queue:start?asyncConsumer=true")
.choice()
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AutowiredConnectionFactoryTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AutowiredConnectionFactoryTest.java
index 5f965d5..346e6ff 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AutowiredConnectionFactoryTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AutowiredConnectionFactoryTest.java
@@ -53,9 +53,9 @@ public class AutowiredConnectionFactoryTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME)
.to(MOCK_RESULT);
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/EmptyMessageBodyTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/EmptyMessageBodyTest.java
index 74fa8a7..4e99cda 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/EmptyMessageBodyTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/EmptyMessageBodyTest.java
@@ -32,9 +32,9 @@ public class EmptyMessageBodyTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:start").to("mock:result");
}
};
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerAsyncFalseTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerAsyncFalseTest.java
index b80f181..98e8745 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerAsyncFalseTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerAsyncFalseTest.java
@@ -52,10 +52,10 @@ public class InOnlyConsumerAsyncFalseTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME).to("log:before").process(new Processor() {
public void process(Exchange exchange) throws Exception {
beforeThreadName = Thread.currentThread().getName();
@@ -64,7 +64,7 @@ public class InOnlyConsumerAsyncFalseTest extends JmsTestSupport {
}
}
}).process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
afterThreadName = Thread.currentThread().getName();
}
}).to("log:after").to(MOCK_RESULT);
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerDefaultTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerDefaultTest.java
index 02685e8..75db2cf 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerDefaultTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerDefaultTest.java
@@ -39,10 +39,10 @@ public class InOnlyConsumerDefaultTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME).to(MOCK_RESULT);
}
};
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueSynchronousTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueSynchronousTest.java
index 75649e3..cce76a9 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueSynchronousTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueSynchronousTest.java
@@ -39,9 +39,9 @@ public class InOnlyConsumerQueueSynchronousTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME)
.to(MOCK_RESULT);
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueTest.java
index af55fc2..0241b54 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueTest.java
@@ -50,9 +50,9 @@ public class InOnlyConsumerQueueTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME)
.to(MOCK_RESULT);
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTempQueueTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTempQueueTest.java
index ba23bfd..826785d 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTempQueueTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTempQueueTest.java
@@ -39,9 +39,9 @@ public class InOnlyConsumerTempQueueTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME)
.to(MOCK_RESULT);
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTopicTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTopicTest.java
index 4e20482..903f9c9 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTopicTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerTopicTest.java
@@ -38,9 +38,9 @@ public class InOnlyConsumerTopicTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:topic:in.only.topic").to("log:request").process(new Processor() {
public void process(Exchange exchange) throws Exception {
String body = (String) exchange.getIn().getBody();
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyPooledExchangeTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyPooledExchangeTest.java
index 9ddbf05..4596541 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyPooledExchangeTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyPooledExchangeTest.java
@@ -60,9 +60,9 @@ public class InOnlyPooledExchangeTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(SJMS_QUEUE_NAME)
.to(MOCK_RESULT);
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyQueueConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyQueueConsumerTest.java
index 1e457c1..461ec7d 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyQueueConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyQueueConsumerTest.java
@@ -45,13 +45,12 @@ public class InOnlyQueueConsumerTest extends JmsTestSupport {
}
/**
- * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
+ * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
*
* @return
- * @throws Exception
*/
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicConsumerTest.java
index 48ad7fe..83bba49 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicConsumerTest.java
@@ -45,13 +45,12 @@ public class InOnlyTopicConsumerTest extends JmsTestSupport {
}
/**
- * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
+ * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
*
* @return
- * @throws Exception
*/
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
index f435a57..bb7db6c 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
@@ -59,10 +59,10 @@ public class InOnlyTopicDurableConsumerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms:topic:foo?durableSubscriptionName=bar1")
.to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConcurrentConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConcurrentConsumerTest.java
index b45f712..190a511 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConcurrentConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConcurrentConsumerTest.java
@@ -73,9 +73,9 @@ public class InOutConcurrentConsumerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("sjms:a?replyToConcurrentConsumers=5&replyTo=myResponse")
.to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueAsyncTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueAsyncTest.java
index 15bccea..67eba1b 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueAsyncTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueAsyncTest.java
@@ -36,9 +36,9 @@ public class InOutConsumerQueueAsyncTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:start?asyncConsumer=true")
.log("Requesting ${body} with thread ${threadName}")
.to(ExchangePattern.InOut,
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueTest.java
index ecb3f9a..284b19b 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerQueueTest.java
@@ -35,9 +35,9 @@ public class InOutConsumerQueueTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:start").to("log:request")
.to("sjms:queue:in.out.queue?exchangePattern=InOut&replyTo=in.out.queue.response")
.to("log:response").to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueAsyncTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueAsyncTest.java
index 0e94068..7ce365b 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueAsyncTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueAsyncTest.java
@@ -36,9 +36,9 @@ public class InOutConsumerTempQueueAsyncTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:start?asyncConsumer=true")
.log("Requesting ${body} with thread ${threadName}")
.to(ExchangePattern.InOut, "sjms:queue:in.out.temp.queue?replyToConcurrentConsumers=2")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueTest.java
index fafa8a3..3854f99 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTempQueueTest.java
@@ -34,9 +34,9 @@ public class InOutConsumerTempQueueTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:start").to("sjms:queue:in.out.temp.queue?exchangePattern=InOut")
.to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTopicTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTopicTest.java
index 51ea7ca..46d28e2 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTopicTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutConsumerTopicTest.java
@@ -39,9 +39,9 @@ public class InOutConsumerTopicTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("sjms:topic:start").to("log:request")
.to("sjms:topic:in.out.topic?exchangePattern=InOut&replyTo=in.out.topic.response")
.to("log:response").to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutSynchronousConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutSynchronousConsumerTest.java
index 3a565da..6db8b10 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutSynchronousConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOutSynchronousConsumerTest.java
@@ -31,7 +31,7 @@ public class InOutSynchronousConsumerTest extends JmsTestSupport {
private String url = "sjms:queue:in?replyTo=response.queue&synchronous=true";
@Test
- public void testSynchronous() throws Exception {
+ public void testSynchronous() {
String reply = template.requestBody("direct:start", "Hello World", String.class);
assertEquals("Bye World", reply);
@@ -39,9 +39,9 @@ public class InOutSynchronousConsumerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("log:before")
.process(exchange -> beforeThreadName = Thread.currentThread().getName())
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/JmsPollingConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/JmsPollingConsumerTest.java
index be0bc3f..b7120d4 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/JmsPollingConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/JmsPollingConsumerTest.java
@@ -112,10 +112,10 @@ public class JmsPollingConsumerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").log("Sending ${body} to queue.start").to("sjms:queue.start");
from("sjms:queue.foo").log("Received ${body} from queue.start").to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutIT.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutIT.java
index 2288380..2d3149a 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutIT.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutIT.java
@@ -51,10 +51,10 @@ public class AsyncJmsInOutIT extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:start")
.to("sjms:queue:in.foo?asyncConsumer=true&replyTo=out.bar&exchangePattern=InOut")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutTempDestIT.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutTempDestIT.java
index 0e37e78..7d8682c 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutTempDestIT.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/AsyncJmsInOutTempDestIT.java
@@ -51,10 +51,10 @@ public class AsyncJmsInOutTempDestIT extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:start")
.to("sjms:in.foo.tempQ?exchangePattern=InOut")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutIT.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutIT.java
index aed525f..60b5c51 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutIT.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutIT.java
@@ -51,10 +51,10 @@ public class SyncJmsInOutIT extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:start")
.to("sjms:queue:in.foo?replyTo=out.bar&exchangePattern=InOut")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutTempDestIT.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutTempDestIT.java
index 3e1bf60..1a02021 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutTempDestIT.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/it/SyncJmsInOutTempDestIT.java
@@ -51,10 +51,10 @@ public class SyncJmsInOutTempDestIT extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:start")
.to("sjms:in.foo.tempQ?exchangePattern=InOut")
.to("mock:result");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/DestinationNameParserTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/DestinationNameParserTest.java
index ec6e7b8..bf66202 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/DestinationNameParserTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/DestinationNameParserTest.java
@@ -26,27 +26,27 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class DestinationNameParserTest {
@Test
- public void testIsTopic() throws Exception {
+ public void testIsTopic() {
assertTrue(DestinationNameParser.isTopic("topic:foo"));
assertFalse(DestinationNameParser.isTopic("queue:bar"));
assertFalse(DestinationNameParser.isTopic("bar"));
}
@Test
- public void testIsTopicNullDestinationName() throws Exception {
+ public void testIsTopicNullDestinationName() {
assertThrows(IllegalArgumentException.class,
() -> DestinationNameParser.isTopic(null));
}
@Test
- public void testGetShortName() throws Exception {
+ public void testGetShortName() {
assertEquals("foo", DestinationNameParser.getShortName("topic:foo"));
assertFalse(DestinationNameParser.isTopic("queue:bar"), "bar");
assertFalse(DestinationNameParser.isTopic("bar"), "bar");
}
@Test
- public void testGetShortNameNullDestinationName() throws Exception {
+ public void testGetShortNameNullDestinationName() {
assertThrows(IllegalArgumentException.class,
() -> DestinationNameParser.getShortName(null));
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/manual/ManualFromQueueTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/manual/ManualFromQueueTest.java
index ab29f2b..556421e 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/manual/ManualFromQueueTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/manual/ManualFromQueueTest.java
@@ -59,10 +59,10 @@ public class ManualFromQueueTest extends CamelTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms:queue:foo?asyncStartListener=true")
.to("log:foo")
.to("mock:foo");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncQueueProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncQueueProducerTest.java
index ab3a132..c21f2f3 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncQueueProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncQueueProducerTest.java
@@ -69,23 +69,23 @@ public class AsyncQueueProducerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
.to("mock:before")
.to("log:before")
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
beforeThreadName = Thread.currentThread().getName();
}
})
.to("async:bye:camel")
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
afterThreadName = Thread.currentThread().getName();
}
})
@@ -96,7 +96,7 @@ public class AsyncQueueProducerTest extends CamelTestSupport {
.to("log:after")
.delay(1000)
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
route += "B";
sedaThreadName = Thread.currentThread().getName();
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncTopicProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncTopicProducerTest.java
index bf04b87..027f959 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncTopicProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/AsyncTopicProducerTest.java
@@ -69,23 +69,23 @@ public class AsyncTopicProducerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("async", new MyAsyncComponent());
from("direct:start")
.to("mock:before")
.to("log:before")
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
beforeThreadName = Thread.currentThread().getName();
}
})
.to("async:bye:camel")
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
afterThreadName = Thread.currentThread().getName();
}
})
@@ -96,7 +96,7 @@ public class AsyncTopicProducerTest extends CamelTestSupport {
.to("log:after")
.delay(1000)
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
route += "B";
sedaThreadName = Thread.currentThread().getName();
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyQueueProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyQueueProducerTest.java
index 78f2602..0d9cd0e 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyQueueProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyQueueProducerTest.java
@@ -93,7 +93,7 @@ public class InOnlyQueueProducerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyTopicProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyTopicProducerTest.java
index f0b71e4..528cd7c 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyTopicProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOnlyTopicProducerTest.java
@@ -67,13 +67,12 @@ public class InOnlyTopicProducerTest extends JmsTestSupport {
}
/**
- * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
+ * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
*
* @return
- * @throws Exception
*/
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerAsyncLoadTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerAsyncLoadTest.java
index c5cfddc..91bcbae 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerAsyncLoadTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerAsyncLoadTest.java
@@ -112,7 +112,7 @@ public class InOutQueueProducerAsyncLoadTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerSyncLoadTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerSyncLoadTest.java
index 79dbe00..9951cab 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerSyncLoadTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerSyncLoadTest.java
@@ -77,7 +77,7 @@ public class InOutQueueProducerSyncLoadTest extends JmsTestSupport {
* Test to verify that when using the consumer listener for the InOut producer we get the correct message back.
*/
@Test
- public void testInOutQueueProducer() throws Exception {
+ public void testInOutQueueProducer() {
ExecutorService executor = Executors.newFixedThreadPool(2);
@@ -110,7 +110,7 @@ public class InOutQueueProducerSyncLoadTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerTest.java
index 5a21633..76bb96e 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/InOutQueueProducerTest.java
@@ -107,7 +107,7 @@ public class InOutQueueProducerTest extends JmsTestSupport {
* @throws Exception
*/
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerQoSTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerQoSTest.java
index e77b74e..5319dfe 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerQoSTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerQoSTest.java
@@ -140,10 +140,10 @@ public class QueueProducerQoSTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms:topic:ActiveMQ.Advisory.Expired.Queue.>")
.routeId(EXPIRED_MESSAGE_ROUTE_ID)
.log("Expired message")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerTest.java
index a2cf7c4..5c979a1 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/QueueProducerTest.java
@@ -67,7 +67,7 @@ public class QueueProducerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java
index 5a2069d..cb998ae 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTest.java
@@ -25,7 +25,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class SjmsToDSendDynamicTest extends JmsTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
@@ -41,10 +41,10 @@ public class SjmsToDSendDynamicTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("sjms:queue:${header.where}");
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoDisabledTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoDisabledTest.java
index a4fa344..af2370c 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoDisabledTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoDisabledTest.java
@@ -25,7 +25,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class SjmsToDSendDynamicTwoDisabledTest extends JmsTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
template.sendBodyAndHeader("direct:start", "Hello gin", "where", "gin");
@@ -39,10 +39,10 @@ public class SjmsToDSendDynamicTwoDisabledTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD but turn off send dynamic aware
from("direct:start").toD().allowOptimisedComponents(false).uri("sjms:queue:${header.where}");
from("direct:start2").toD().allowOptimisedComponents(false).uri("sjms:queue:${header.where2}");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoTest.java
index 07d4a33..0ce3aa4 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDSendDynamicTwoTest.java
@@ -25,7 +25,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class SjmsToDSendDynamicTwoTest extends JmsTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
template.sendBodyAndHeader("direct:start", "Hello gin", "where", "gin");
@@ -39,10 +39,10 @@ public class SjmsToDSendDynamicTwoTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("sjms:queue:${header.where}");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java
index 707ce6a..40ace38 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/producer/SjmsToDTest.java
@@ -34,10 +34,10 @@ public class SjmsToDTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("sjms:queue:${header.where}");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/MyAsyncEndpoint.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/MyAsyncEndpoint.java
index 1a28be1..a05fc7a 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/MyAsyncEndpoint.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/MyAsyncEndpoint.java
@@ -38,7 +38,7 @@ public class MyAsyncEndpoint extends DefaultEndpoint {
}
@Override
- public Producer createProducer() throws Exception {
+ public Producer createProducer() {
Producer answer = new MyAsyncProducer(this);
if (isSynchronous()) {
// force it to be synchronously
@@ -49,7 +49,7 @@ public class MyAsyncEndpoint extends DefaultEndpoint {
}
@Override
- public Consumer createConsumer(Processor processor) throws Exception {
+ public Consumer createConsumer(Processor processor) {
throw new UnsupportedOperationException("Consumer not supported");
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/SjmsConnectionTestSupport.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/SjmsConnectionTestSupport.java
index c75f1e6..3c0ea34 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/SjmsConnectionTestSupport.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/SjmsConnectionTestSupport.java
@@ -43,11 +43,11 @@ public abstract class SjmsConnectionTestSupport {
public abstract String getConnectionUri();
@BeforeAll
- public static void setUpBeforeClass() throws Exception {
+ public static void setUpBeforeClass() {
}
@AfterAll
- public static void tearDownAfterClass() throws Exception {
+ public static void tearDownAfterClass() {
}
@BeforeEach
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/threadpool/ThreadPoolTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/threadpool/ThreadPoolTest.java
index 92e2aa7..36aaa33 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/threadpool/ThreadPoolTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/threadpool/ThreadPoolTest.java
@@ -50,10 +50,10 @@ public class ThreadPoolTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("sjms:queue:foo").routeId(FROM_ROUTE);
from("sjms:queue:foo").to("log:test.log.1?showBody=true").routeId(TO_ROUTE);
}
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedAsyncExceptionTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedAsyncExceptionTest.java
index f4766a7..6ca71c0 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedAsyncExceptionTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedAsyncExceptionTest.java
@@ -48,7 +48,7 @@ public class TransactedAsyncExceptionTest extends CamelTestSupport {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
AtomicInteger counter = new AtomicInteger();
from(destination + "?acknowledgementMode=SESSION_TRANSACTED&transacted=true")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumerSupport.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumerSupport.java
index 68dbf45..6130554 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumerSupport.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumerSupport.java
@@ -115,7 +115,7 @@ public abstract class TransactedConsumerSupport extends CamelTestSupport {
private final AtomicInteger counter = new AtomicInteger();
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (counter.incrementAndGet() == maxAttemptsCount) {
log.info(
"{} Messages have been processed. Failing the exchange to force a rollback of the transaction.",
@@ -133,7 +133,7 @@ public abstract class TransactedConsumerSupport extends CamelTestSupport {
.to("mock:test.after." + routeNumber)
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// Countdown the latch
latch.countDown();
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedOnCompletionTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedOnCompletionTest.java
index 7690f24..97394a8 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedOnCompletionTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedOnCompletionTest.java
@@ -52,7 +52,7 @@ public class TransactedOnCompletionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedProducerInOutErrorTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedProducerInOutErrorTest.java
index 57d1218..d015bdd 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedProducerInOutErrorTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedProducerInOutErrorTest.java
@@ -47,10 +47,10 @@ public class TransactedProducerInOutErrorTest {
LOG.info("Exception was thrown as expected", t);
}
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("sjms:queue:test-in?replyTo=test-out&exchangePattern=InOut&transacted=true")
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueInOutProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueInOutProducerTest.java
index c876faa..80212ef 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueInOutProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueInOutProducerTest.java
@@ -64,7 +64,7 @@ public class TransactedQueueInOutProducerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
index fe2184b..3264895 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
@@ -63,7 +63,7 @@ public class TransactedQueueProducerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
index 3682237..4509c1e 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
@@ -65,7 +65,7 @@ public class TransactedTopicProducerTest extends JmsTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
[camel] 01/02: CAMEL-17763: cleaned up unused exceptions in camel-sjms2
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3de7b649d1a8f34227de0adae44a4a9cbd419a83
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu Mar 10 14:53:26 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-sjms2
---
.../component/sjms2/SimpleJms2ComponentTest.java | 4 ++--
.../component/sjms2/Sjms2ComponentRestartTest.java | 4 ++--
.../sjms2/Sjms2EndpointNameOverrideTest.java | 6 +++---
.../camel/component/sjms2/Sjms2EndpointTest.java | 22 +++++++++++-----------
.../consumer/InOnlyTopicDurableConsumerTest.java | 4 ++--
.../consumer/InOnlyTopicSharedConsumerTest.java | 2 +-
.../sjms2/producer/InOnlyQueueProducerTest.java | 2 +-
.../sjms2/producer/InOnlyTopicProducerTest.java | 5 ++---
.../sjms2/producer/Sjms2ToDSendDynamicTest.java | 6 +++---
9 files changed, 27 insertions(+), 28 deletions(-)
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/SimpleJms2ComponentTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/SimpleJms2ComponentTest.java
index 0d386cb..7d97228 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/SimpleJms2ComponentTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/SimpleJms2ComponentTest.java
@@ -26,13 +26,13 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class SimpleJms2ComponentTest extends CamelTestSupport {
@Test
- public void testHelloWorld() throws Exception {
+ public void testHelloWorld() {
Sjms2Component component = context.getComponent("sjms2", Sjms2Component.class);
assertNotNull(component);
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
ActiveMQConnectionFactory connectionFactory
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2ComponentRestartTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2ComponentRestartTest.java
index fb943f6..daf192e 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2ComponentRestartTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2ComponentRestartTest.java
@@ -37,7 +37,7 @@ public class Sjms2ComponentRestartTest extends CamelTestSupport {
public void testRestartWithStopStart() throws Exception {
RouteBuilder routeBuilder = new RouteBuilder(context) {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms2:queue:test").to("mock:test");
}
};
@@ -73,7 +73,7 @@ public class Sjms2ComponentRestartTest extends CamelTestSupport {
public void testRestartWithSuspendResume() throws Exception {
RouteBuilder routeBuilder = new RouteBuilder(context) {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms2:queue:test").to("mock:test");
}
};
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointNameOverrideTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointNameOverrideTest.java
index 9fd58c3..c009e61 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointNameOverrideTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointNameOverrideTest.java
@@ -37,7 +37,7 @@ public class Sjms2EndpointNameOverrideTest extends CamelTestSupport {
}
@Test
- public void testDefaults() throws Exception {
+ public void testDefaults() {
Endpoint endpoint = context.getEndpoint(BEAN_NAME + ":test");
assertNotNull(endpoint);
assertTrue(endpoint instanceof Sjms2Endpoint);
@@ -47,7 +47,7 @@ public class Sjms2EndpointNameOverrideTest extends CamelTestSupport {
}
@Test
- public void testQueueEndpoint() throws Exception {
+ public void testQueueEndpoint() {
Endpoint sjms = context.getEndpoint(BEAN_NAME + ":queue:test");
assertNotNull(sjms);
assertTrue(sjms instanceof Sjms2Endpoint);
@@ -55,7 +55,7 @@ public class Sjms2EndpointNameOverrideTest extends CamelTestSupport {
}
@Test
- public void testTopicEndpoint() throws Exception {
+ public void testTopicEndpoint() {
Endpoint sjms = context.getEndpoint(BEAN_NAME + ":topic:test");
assertNotNull(sjms);
assertTrue(sjms instanceof Sjms2Endpoint);
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointTest.java
index 844f5c0..8f03013 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/Sjms2EndpointTest.java
@@ -33,7 +33,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testDefaults() throws Exception {
+ public void testDefaults() {
Endpoint endpoint = context.getEndpoint("sjms2:test");
assertNotNull(endpoint);
assertTrue(endpoint instanceof Sjms2Endpoint);
@@ -43,7 +43,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testQueueEndpoint() throws Exception {
+ public void testQueueEndpoint() {
Endpoint sjms = context.getEndpoint("sjms2:queue:test");
assertNotNull(sjms);
assertEquals("sjms2://queue:test", sjms.getEndpointUri());
@@ -51,7 +51,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testJndiStyleEndpointName() throws Exception {
+ public void testJndiStyleEndpointName() {
Sjms2Endpoint sjms = context.getEndpoint("sjms2:/jms/test/hov.t1.dev:topic", Sjms2Endpoint.class);
assertNotNull(sjms);
assertFalse(sjms.isTopic());
@@ -59,7 +59,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testSetTransacted() throws Exception {
+ public void testSetTransacted() {
Endpoint endpoint = context.getEndpoint("sjms2:queue:test?transacted=true");
assertNotNull(endpoint);
assertTrue(endpoint instanceof Sjms2Endpoint);
@@ -68,7 +68,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testAsyncProducer() throws Exception {
+ public void testAsyncProducer() {
Endpoint endpoint = context.getEndpoint("sjms2:queue:test?synchronous=true");
assertNotNull(endpoint);
assertTrue(endpoint instanceof Sjms2Endpoint);
@@ -77,7 +77,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testReplyTo() throws Exception {
+ public void testReplyTo() {
String replyTo = "reply.to.queue";
Endpoint endpoint = context.getEndpoint("sjms2:queue:test?replyTo=" + replyTo);
assertNotNull(endpoint);
@@ -88,7 +88,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testDefaultExchangePattern() throws Exception {
+ public void testDefaultExchangePattern() {
try {
Sjms2Endpoint sjms = (Sjms2Endpoint) context.getEndpoint("sjms2:queue:test");
assertNotNull(sjms);
@@ -99,7 +99,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testInOnlyExchangePattern() throws Exception {
+ public void testInOnlyExchangePattern() {
try {
Endpoint sjms = context.getEndpoint("sjms2:queue:test?exchangePattern=" + ExchangePattern.InOnly);
assertNotNull(sjms);
@@ -110,7 +110,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testInOutExchangePattern() throws Exception {
+ public void testInOutExchangePattern() {
try {
Endpoint sjms = context.getEndpoint("sjms2:queue:test?exchangePattern=" + ExchangePattern.InOut);
assertNotNull(sjms);
@@ -121,7 +121,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testReplyToAndMEPMatch() throws Exception {
+ public void testReplyToAndMEPMatch() {
String replyTo = "reply.to.queue";
Endpoint endpoint = context
.getEndpoint("sjms2:queue:test?replyTo=" + replyTo + "&exchangePattern=" + ExchangePattern.InOut);
@@ -133,7 +133,7 @@ public class Sjms2EndpointTest extends CamelTestSupport {
}
@Test
- public void testDestinationName() throws Exception {
+ public void testDestinationName() {
Endpoint endpoint = context.getEndpoint("sjms2:queue:test?synchronous=true");
assertNotNull(endpoint);
assertTrue(endpoint instanceof Sjms2Endpoint);
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicDurableConsumerTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicDurableConsumerTest.java
index b38747c..7454750 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicDurableConsumerTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicDurableConsumerTest.java
@@ -64,10 +64,10 @@ public class InOnlyTopicDurableConsumerTest extends Jms2TestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sjms2:topic:foo?durableSubscriptionName=bar1")
.to("mock:result");
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicSharedConsumerTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicSharedConsumerTest.java
index ba2d897..1993ec7 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicSharedConsumerTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/consumer/InOnlyTopicSharedConsumerTest.java
@@ -48,7 +48,7 @@ public class InOnlyTopicSharedConsumerTest extends Jms2TestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyQueueProducerTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyQueueProducerTest.java
index 68e7ee6..6d4a5bc 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyQueueProducerTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyQueueProducerTest.java
@@ -85,7 +85,7 @@ public class InOnlyQueueProducerTest extends Jms2TestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyTopicProducerTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyTopicProducerTest.java
index 9369beb..f1511d3 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyTopicProducerTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/InOnlyTopicProducerTest.java
@@ -67,13 +67,12 @@ public class InOnlyTopicProducerTest extends Jms2TestSupport {
}
/**
- * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
+ * @see org.apache.camel.test.junit5.CamelTestSupport#createRouteBuilder()
*
* @return
- * @throws Exception
*/
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:start")
diff --git a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/Sjms2ToDSendDynamicTest.java b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/Sjms2ToDSendDynamicTest.java
index 8499cdc..a223641 100644
--- a/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/Sjms2ToDSendDynamicTest.java
+++ b/components/camel-sjms2/src/test/java/org/apache/camel/component/sjms2/producer/Sjms2ToDSendDynamicTest.java
@@ -25,7 +25,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class Sjms2ToDSendDynamicTest extends Jms2TestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
@@ -41,10 +41,10 @@ public class Sjms2ToDSendDynamicTest extends Jms2TestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("sjms2:queue:${header.where}");
}