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
The following commit(s) were added to refs/heads/main by this push:
new a7bd884 (chores) camel-atomix cleanup throws (#5697)
a7bd884 is described below
commit a7bd8843025b511510fa22234907baa5fd6ddc8e
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Thu Jun 17 15:49:31 2021 +0200
(chores) camel-atomix cleanup throws (#5697)
- remove unused throws
- use more specific ones when applicable
---
.../client/AbstractAtomixClientComponent.java | 2 +-
.../atomix/client/map/AtomixMapProducer.java | 24 +++++++++++-----------
.../client/messaging/AtomixMessagingProducer.java | 4 ++--
.../client/multimap/AtomixMultiMapProducer.java | 20 +++++++++---------
.../atomix/client/queue/AtomixQueueProducer.java | 18 ++++++++--------
.../atomix/client/set/AtomixSetProducer.java | 12 +++++------
.../atomix/client/value/AtomixValueProducer.java | 8 ++++----
.../atomix/cluster/AtomixClusterHelper.java | 3 ++-
.../atomix/cluster/AtomixClusterView.java | 3 +--
9 files changed, 47 insertions(+), 47 deletions(-)
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientComponent.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientComponent.java
index 11bb9ed..b3a9453 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientComponent.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientComponent.java
@@ -84,7 +84,7 @@ public abstract class AbstractAtomixClientComponent<C extends
AtomixClientConfig
// Properties
// *****************************************
- protected C setConfigurationProperties(C configuration, Map<String,
Object> parameters) throws Exception {
+ protected C setConfigurationProperties(C configuration, Map<String,
Object> parameters) {
// Resolve config for named maps
Map<String, Object> configs =
PropertiesHelper.extractProperties(parameters, "resource.config.");
for (Map.Entry<String, Object> entry : configs.entrySet()) {
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/map/AtomixMapProducer.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/map/AtomixMapProducer.java
index ca79ee5..27299b2 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/map/AtomixMapProducer.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/map/AtomixMapProducer.java
@@ -52,7 +52,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("PUT")
- void onPut(Message message, AsyncCallback callback) throws Exception {
+ void onPut(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final Object key = message.getHeader(RESOURCE_KEY,
configuration::getKey, Object.class);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -71,7 +71,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("PUT_IF_ABSENT")
- void onPutIfAbsent(Message message, AsyncCallback callback) throws
Exception {
+ void onPutIfAbsent(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final Object key = message.getHeader(RESOURCE_KEY,
configuration::getKey, Object.class);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -90,7 +90,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("GET")
- void onGet(Message message, AsyncCallback callback) throws Exception {
+ void onGet(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final Object key = message.getHeader(RESOURCE_KEY,
configuration::getKey, Object.class);
final Object defaultValue = message.getHeader(RESOURCE_DEFAULT_VALUE);
@@ -119,7 +119,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("CLEAR")
- void onClear(Message message, AsyncCallback callback) throws Exception {
+ void onClear(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
map.clear().thenAccept(
@@ -127,7 +127,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("SIZE")
- void onSize(Message message, AsyncCallback callback) throws Exception {
+ void onSize(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -142,7 +142,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("IS_EMPTY")
- void onIsEmpty(Message message, AsyncCallback callback) throws Exception {
+ void onIsEmpty(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -157,7 +157,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("ENTRY_SET")
- void onEntrySet(Message message, AsyncCallback callback) throws Exception {
+ void onEntrySet(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -172,7 +172,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("VALUES")
- void onValues(Message message, AsyncCallback callback) throws Exception {
+ void onValues(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -187,7 +187,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("CONTAINS_KEY")
- void onContainsKey(Message message, AsyncCallback callback) throws
Exception {
+ void onContainsKey(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -205,7 +205,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("CONTAINS_VALUE")
- void onContainsValue(Message message, AsyncCallback callback) throws
Exception {
+ void onContainsValue(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -223,7 +223,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("REMOVE")
- void onRemove(Message message, AsyncCallback callback) throws Exception {
+ void onRemove(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final Object key = message.getHeader(RESOURCE_KEY, message::getBody,
Object.class);
final Object value = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
@@ -240,7 +240,7 @@ public final class AtomixMapProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("REPLACE")
- void onReplace(Message message, AsyncCallback callback) throws Exception {
+ void onReplace(Message message, AsyncCallback callback) {
final DistributedMap<Object, Object> map = getResource(message);
final long ttl = getResourceTtl(message);
final Object key = message.getHeader(RESOURCE_KEY,
configuration::getKey, Object.class);
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/messaging/AtomixMessagingProducer.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/messaging/AtomixMessagingProducer.java
index a062824..de56d14 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/messaging/AtomixMessagingProducer.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/messaging/AtomixMessagingProducer.java
@@ -47,7 +47,7 @@ public final class AtomixMessagingProducer extends
AbstractAtomixClientProducer<
// *********************************
@InvokeOnHeader("DIRECT")
- void onDirect(Message message, AsyncCallback callback) throws Exception {
+ void onDirect(Message message, AsyncCallback callback) {
final Object value = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
final String memberName = message.getHeader(MEMBER_NAME,
configuration::getMemberName, String.class);
final String channelName = message.getHeader(CHANNEL_NAME,
configuration::getChannelName, String.class);
@@ -65,7 +65,7 @@ public final class AtomixMessagingProducer extends
AbstractAtomixClientProducer<
}
@InvokeOnHeader("BROADCAST")
- void onBroadcast(Message message, AsyncCallback callback) throws Exception
{
+ void onBroadcast(Message message, AsyncCallback callback) {
final Object value = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
final String channelName = message.getHeader(CHANNEL_NAME,
configuration::getChannelName, String.class);
final AtomixMessaging.BroadcastType type
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/multimap/AtomixMultiMapProducer.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/multimap/AtomixMultiMapProducer.java
index 4d89c2f..0c5b362 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/multimap/AtomixMultiMapProducer.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/multimap/AtomixMultiMapProducer.java
@@ -50,7 +50,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("PUT")
- void onPut(Message message, AsyncCallback callback) throws Exception {
+ void onPut(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final Object key = message.getHeader(RESOURCE_KEY,
configuration::getKey, Object.class);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -69,7 +69,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("GET")
- void onGet(Message message, AsyncCallback callback) throws Exception {
+ void onGet(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final Object key = message.getHeader(RESOURCE_KEY,
configuration::getKey, Object.class);
final ReadConsistency consistency
@@ -87,7 +87,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("CLEAR")
- void onClear(Message message, AsyncCallback callback) throws Exception {
+ void onClear(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
map.clear().thenAccept(
@@ -95,7 +95,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("SIZE")
- void onSize(Message message, AsyncCallback callback) throws Exception {
+ void onSize(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -121,7 +121,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("IS_EMPTY")
- void onIsEmpty(Message message, AsyncCallback callback) throws Exception {
+ void onIsEmpty(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -136,7 +136,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("CONTAINS_KEY")
- void onContainsKey(Message message, AsyncCallback callback) throws
Exception {
+ void onContainsKey(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -154,7 +154,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("CONTAINS_VALUE")
- void onContainsValue(Message message, AsyncCallback callback) throws
Exception {
+ void onContainsValue(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -172,7 +172,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("CONTAINS_ENTRY")
- void onContainsEntry(Message message, AsyncCallback callback) throws
Exception {
+ void onContainsEntry(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -192,7 +192,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("REMOVE")
- void onRemove(Message message, AsyncCallback callback) throws Exception {
+ void onRemove(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final Object key = message.getHeader(RESOURCE_KEY, message::getBody,
Object.class);
final Object value = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
@@ -209,7 +209,7 @@ public final class AtomixMultiMapProducer extends
AbstractAtomixClientProducer<A
}
@InvokeOnHeader("REMOVE_VALUE")
- void onRemoveValue(Message message, AsyncCallback callback) throws
Exception {
+ void onRemoveValue(Message message, AsyncCallback callback) {
final DistributedMultiMap<Object, Object> map = getResource(message);
final Object value = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/queue/AtomixQueueProducer.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/queue/AtomixQueueProducer.java
index 2415fdb..8a11c3a 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/queue/AtomixQueueProducer.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/queue/AtomixQueueProducer.java
@@ -41,7 +41,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
// *********************************
@InvokeOnHeader("ADD")
- void onAdd(Message message, AsyncCallback callback) throws Exception {
+ void onAdd(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -52,7 +52,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("OFFER")
- void onOffer(Message message, AsyncCallback callback) throws Exception {
+ void onOffer(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -63,7 +63,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("PEEK")
- void onPeek(Message message, AsyncCallback callback) throws Exception {
+ void onPeek(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
queue.peek().thenAccept(
@@ -71,7 +71,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("POLL")
- void onPoll(Message message, AsyncCallback callback) throws Exception {
+ void onPoll(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
queue.poll().thenAccept(
@@ -79,7 +79,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("CLEAR")
- void onClear(Message message, AsyncCallback callback) throws Exception {
+ void onClear(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
queue.clear().thenAccept(
@@ -87,7 +87,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("CONTAINS")
- void onContains(Message message, AsyncCallback callback) throws Exception {
+ void onContains(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -105,7 +105,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("IS_EMPTY")
- void onIsEmpty(Message message, AsyncCallback callback) throws Exception {
+ void onIsEmpty(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -120,7 +120,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("REMOVE")
- void onRemove(Message message, AsyncCallback callback) throws Exception {
+ void onRemove(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
final Object value = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
@@ -134,7 +134,7 @@ public final class AtomixQueueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("SIZE")
- void onSize(Message message, AsyncCallback callback) throws Exception {
+ void onSize(Message message, AsyncCallback callback) {
final DistributedQueue<Object> queue = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/set/AtomixSetProducer.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/set/AtomixSetProducer.java
index f10c1e4..01c8024 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/set/AtomixSetProducer.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/set/AtomixSetProducer.java
@@ -49,7 +49,7 @@ public final class AtomixSetProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("ADD")
- void onAdd(Message message, AsyncCallback callback) throws Exception {
+ void onAdd(Message message, AsyncCallback callback) {
final DistributedSet<Object> set = getResource(message);
final long ttl = getResourceTtl(message);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -66,7 +66,7 @@ public final class AtomixSetProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("CLEAR")
- void onClear(Message message, AsyncCallback callback) throws Exception {
+ void onClear(Message message, AsyncCallback callback) {
final DistributedSet<Object> set = getResource(message);
set.clear().thenAccept(
@@ -74,7 +74,7 @@ public final class AtomixSetProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("CONTAINS")
- void onContains(Message message, AsyncCallback callback) throws Exception {
+ void onContains(Message message, AsyncCallback callback) {
final DistributedSet<Object> set = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -92,7 +92,7 @@ public final class AtomixSetProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("IS_EMPTY")
- void onIsEmpty(Message message, AsyncCallback callback) throws Exception {
+ void onIsEmpty(Message message, AsyncCallback callback) {
final DistributedSet<Object> set = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -107,7 +107,7 @@ public final class AtomixSetProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("REMOVE")
- void onRemove(Message message, AsyncCallback callback) throws Exception {
+ void onRemove(Message message, AsyncCallback callback) {
final DistributedSet<Object> set = getResource(message);
final Object value = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
@@ -118,7 +118,7 @@ public final class AtomixSetProducer extends
AbstractAtomixClientProducer<Atomix
}
@InvokeOnHeader("SIZE")
- void onSize(Message message, AsyncCallback callback) throws Exception {
+ void onSize(Message message, AsyncCallback callback) {
final DistributedSet<Object> set = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueProducer.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueProducer.java
index f827ecd..85845ae 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueProducer.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/value/AtomixValueProducer.java
@@ -50,7 +50,7 @@ public final class AtomixValueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("SET")
- void onSet(Message message, AsyncCallback callback) throws Exception {
+ void onSet(Message message, AsyncCallback callback) {
final DistributedValue<Object> value = getResource(message);
final long ttl = getResourceTtl(message);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -67,7 +67,7 @@ public final class AtomixValueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("GET")
- void onGet(Message message, AsyncCallback callback) throws Exception {
+ void onGet(Message message, AsyncCallback callback) {
final DistributedValue<Object> value = getResource(message);
final ReadConsistency consistency
= message.getHeader(RESOURCE_READ_CONSISTENCY,
configuration::getReadConsistency, ReadConsistency.class);
@@ -82,7 +82,7 @@ public final class AtomixValueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("GET_AND_SET")
- void onGetAndSet(Message message, AsyncCallback callback) throws Exception
{
+ void onGetAndSet(Message message, AsyncCallback callback) {
final DistributedValue<Object> value = getResource(message);
final long ttl = getResourceTtl(message);
final Object val = message.getHeader(RESOURCE_VALUE, message::getBody,
Object.class);
@@ -99,7 +99,7 @@ public final class AtomixValueProducer extends
AbstractAtomixClientProducer<Atom
}
@InvokeOnHeader("COMPARE_AND_SET")
- void onCompareAndSet(Message message, AsyncCallback callback) throws
Exception {
+ void onCompareAndSet(Message message, AsyncCallback callback) {
final DistributedValue<Object> value = getResource(message);
final long ttl = getResourceTtl(message);
final Object newVal = message.getHeader(RESOURCE_VALUE,
message::getBody, Object.class);
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterHelper.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterHelper.java
index 4f7e023..d0b8ed9 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterHelper.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterHelper.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.atomix.cluster;
+import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
@@ -40,7 +41,7 @@ public final class AtomixClusterHelper {
public static AtomixReplica createReplica(
CamelContext camelContext, Address address,
AtomixClusterConfiguration configuration)
- throws Exception {
+ throws IOException, ClassNotFoundException {
AtomixReplica atomix = (AtomixReplica) configuration.getAtomix();
if (atomix == null) {
diff --git
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java
index 1b52a12..b223021 100644
---
a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java
+++
b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/cluster/AtomixClusterView.java
@@ -19,7 +19,6 @@ package org.apache.camel.component.atomix.cluster;
import java.util.Collections;
import java.util.List;
import java.util.Optional;
-import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;
import io.atomix.Atomix;
@@ -174,7 +173,7 @@ final class AtomixClusterView extends
AbstractCamelClusterView {
return member != null;
}
- AtomixLocalMember join() throws ExecutionException,
InterruptedException {
+ AtomixLocalMember join() {
if (member == null && group != null) {
String id = getClusterService().getId();
if (ObjectHelper.isEmpty(id) || configuration.isEphemeral()) {
