You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bv...@apache.org on 2020/12/04 10:13:39 UTC
[camel] branch master updated: better make use of the AtomicInteger
& AtomicLong default constructors
This is an automated email from the ASF dual-hosted git repository.
bvahdat pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 6d3758f better make use of the AtomicInteger & AtomicLong default constructors
6d3758f is described below
commit 6d3758f34fd3651e360d59370b40b149306872fe
Author: Babak Vahdat <bv...@apache.org>
AuthorDate: Fri Dec 4 11:13:17 2020 +0100
better make use of the AtomicInteger & AtomicLong default constructors
---
.../camel/component/aws/s3/S3ConsumerDelimiterTest.java | 2 +-
.../camel/component/aws/s3/S3ConsumerPrefixTest.java | 2 +-
.../apache/camel/component/aws/s3/S3IncludeBodyTest.java | 2 +-
.../camel/component/aws/xray/bean/ProcessingCamelBean.java | 2 +-
.../apache/camel/component/cxf/CxfPayLoadBareSoapTest.java | 2 +-
.../component/etcd/cloud/EtcdServiceDiscoveryTest.java | 2 +-
.../camel/component/ignite/TestIgniteComputeResources.java | 2 +-
.../component/jira/consumer/NewCommentsConsumerTest.java | 2 +-
.../org/apache/camel/component/jms/CamelJmsTestHelper.java | 2 +-
.../jms/JmsRequestReplyTempQueueMultipleConsumersTest.java | 2 +-
.../component/leveldb/LevelDBAggregateRecoverTest.java | 2 +-
.../LevelDBAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../leveldb/LevelDBAggregateRecoverWithSedaTest.java | 2 +-
...elDBSpringAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../component/leveldb/LevelDBAggregateRecoverTest.java | 2 +-
.../LevelDBAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../leveldb/LevelDBAggregateRecoverWithSedaTest.java | 2 +-
...elDBSpringAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../org/apache/camel/component/nsq/NsqProducerTest.java | 4 ++--
.../component/reactive/streams/support/TestPublisher.java | 2 +-
.../engine/ReactorStreamsServiceSubscriberTest.java | 2 +-
.../reactor/engine/ReactorStreamsServiceTest.java | 6 +++---
.../rxjava/engine/RxJavaStreamsServiceSubscriberTest.java | 2 +-
.../component/rxjava/engine/RxJavaStreamsServiceTest.java | 14 +++++++-------
.../apache/camel/component/sjms/CamelJmsTestHelper.java | 2 +-
.../camel/component/sjms/tx/TransactedConsumerSupport.java | 2 +-
.../soroushbot/component/ConsumerNativeConcurrentTest.java | 2 +-
.../camel/component/sql/stored/TestStoredProcedure.java | 2 +-
.../processor/aggregate/jdbc/JdbcAggregateRecoverTest.java | 2 +-
.../jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java | 2 +-
...JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../camel/component/webhook/WebhookRegistrationTest.java | 4 ++--
.../org/apache/camel/component/bean/BeanLifecycleTest.java | 2 +-
.../strategy/MarkerFileExclusiveReadLockStrategyTest.java | 2 +-
.../camel/component/scheduler/SchedulerRouteTest.java | 2 +-
.../org/apache/camel/component/timer/TimerRouteTest.java | 2 +-
.../camel/impl/DefaultProducerTemplateAsyncTest.java | 2 +-
.../BeanRecipientListInterfaceAnnotationTest.java | 2 +-
.../org/apache/camel/processor/BeanRecipientListTest.java | 2 +-
.../java/org/apache/camel/processor/BeanRouteTest.java | 2 +-
.../apache/camel/processor/RoutePerformanceCountTest.java | 2 +-
.../processor/aggregator/AggregatorConcurrencyTest.java | 4 ++--
.../java/org/apache/camel/util/ReferenceCountTest.java | 2 +-
.../org/apache/camel/util/backoff/BackOffTimerTest.java | 6 +++---
.../java/org/apache/camel/itest/CamelJmsTestHelper.java | 2 +-
46 files changed, 59 insertions(+), 59 deletions(-)
diff --git a/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerDelimiterTest.java b/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerDelimiterTest.java
index 0ffc274..43e7b92 100644
--- a/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerDelimiterTest.java
+++ b/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerDelimiterTest.java
@@ -67,7 +67,7 @@ public class S3ConsumerDelimiterTest extends CamelTestSupport {
class DummyAmazonS3Client extends AmazonS3Client {
- private AtomicInteger requestCount = new AtomicInteger(0);
+ private AtomicInteger requestCount = new AtomicInteger();
DummyAmazonS3Client() {
super(new BasicAWSCredentials("myAccessKey", "mySecretKey"));
diff --git a/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerPrefixTest.java b/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerPrefixTest.java
index 70b6e22..fad14e7 100644
--- a/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerPrefixTest.java
+++ b/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3ConsumerPrefixTest.java
@@ -67,7 +67,7 @@ public class S3ConsumerPrefixTest extends CamelTestSupport {
class DummyAmazonS3Client extends AmazonS3Client {
- private AtomicInteger requestCount = new AtomicInteger(0);
+ private AtomicInteger requestCount = new AtomicInteger();
DummyAmazonS3Client() {
super(new BasicAWSCredentials("myAccessKey", "mySecretKey"));
diff --git a/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3IncludeBodyTest.java b/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3IncludeBodyTest.java
index 5912354..23d8be2 100644
--- a/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3IncludeBodyTest.java
+++ b/components/camel-aws-s3/src/test/java/org/apache/camel/component/aws/s3/S3IncludeBodyTest.java
@@ -67,7 +67,7 @@ public class S3IncludeBodyTest extends CamelTestSupport {
class DummyAmazonS3Client extends AmazonS3Client {
- private AtomicInteger requestCount = new AtomicInteger(0);
+ private AtomicInteger requestCount = new AtomicInteger();
DummyAmazonS3Client() {
super(new BasicAWSCredentials("myAccessKey", "mySecretKey"));
diff --git a/components/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/bean/ProcessingCamelBean.java b/components/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/bean/ProcessingCamelBean.java
index e3e3a53..6308a12 100644
--- a/components/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/bean/ProcessingCamelBean.java
+++ b/components/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/bean/ProcessingCamelBean.java
@@ -24,7 +24,7 @@ import org.apache.camel.component.aws.xray.XRayTrace;
@XRayTrace
public class ProcessingCamelBean {
- private static final AtomicInteger INVOKED = new AtomicInteger(0);
+ private static final AtomicInteger INVOKED = new AtomicInteger();
@Handler
public void performTask() {
diff --git a/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfPayLoadBareSoapTest.java b/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfPayLoadBareSoapTest.java
index ef7b4ac..0865030 100644
--- a/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfPayLoadBareSoapTest.java
+++ b/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfPayLoadBareSoapTest.java
@@ -81,7 +81,7 @@ public class CxfPayLoadBareSoapTest extends CamelTestSupport {
}
public static class BareSoapServiceImpl implements BareSoapService {
- private AtomicInteger invocations = new AtomicInteger(0);
+ private AtomicInteger invocations = new AtomicInteger();
@Override
public void doSomething() {
diff --git a/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/cloud/EtcdServiceDiscoveryTest.java b/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/cloud/EtcdServiceDiscoveryTest.java
index e3fee9f..748a643 100644
--- a/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/cloud/EtcdServiceDiscoveryTest.java
+++ b/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/cloud/EtcdServiceDiscoveryTest.java
@@ -36,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class EtcdServiceDiscoveryTest extends EtcdTestSupport {
private static final ObjectMapper MAPPER = EtcdHelper.createObjectMapper();
- private static final AtomicInteger PORT = new AtomicInteger(0);
+ private static final AtomicInteger PORT = new AtomicInteger();
private EtcdClient client;
private EtcdConfiguration configuration;
diff --git a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/TestIgniteComputeResources.java b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/TestIgniteComputeResources.java
index 0d25146..b3af5a0 100644
--- a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/TestIgniteComputeResources.java
+++ b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/TestIgniteComputeResources.java
@@ -39,7 +39,7 @@ import org.apache.ignite.lang.IgniteRunnable;
public final class TestIgniteComputeResources {
- public static final AtomicInteger COUNTER = new AtomicInteger(0);
+ public static final AtomicInteger COUNTER = new AtomicInteger();
public static final IgniteRunnable TEST_RUNNABLE = new IgniteRunnable() {
private static final long serialVersionUID = -4961602602993218883L;
diff --git a/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewCommentsConsumerTest.java b/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewCommentsConsumerTest.java
index 2c4bc0c..dc7e220 100644
--- a/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewCommentsConsumerTest.java
+++ b/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewCommentsConsumerTest.java
@@ -161,7 +161,7 @@ public class NewCommentsConsumerTest extends CamelTestSupport {
SearchResult searchResult = new SearchResult(0, 50, 3, newIssues);
Promise<SearchResult> searchResultPromise = Promises.promise(searchResult);
when(searchRestClient.searchJql(anyString(), any(), any(), any())).thenReturn(searchResultPromise);
- AtomicInteger regulator = new AtomicInteger(0);
+ AtomicInteger regulator = new AtomicInteger();
when(issueRestClient.getIssue(anyString())).then(inv -> {
int idx = regulator.getAndIncrement();
Issue issue = issueWithNoComments;
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java
index 32dbfc0..f849f9b 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java
@@ -30,7 +30,7 @@ import org.apache.camel.util.FileUtil;
*/
public final class CamelJmsTestHelper {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private CamelJmsTestHelper() {
}
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java
index 59faea2..facb500 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java
@@ -109,7 +109,7 @@ public class JmsRequestReplyTempQueueMultipleConsumersTest extends CamelTestSupp
synchronized (msgsPerThread) {
AtomicInteger count = msgsPerThread.get(threadName);
if (count == null) {
- count = new AtomicInteger(0);
+ count = new AtomicInteger();
msgsPerThread.put(threadName, count);
}
count.incrementAndGet();
diff --git a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
index b22433f..d87881f 100644
--- a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
+++ b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
@@ -31,7 +31,7 @@ import static org.apache.camel.test.junit5.TestSupport.deleteDirectory;
public class LevelDBAggregateRecoverTest extends CamelTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private LevelDBAggregationRepository repo;
@Override
diff --git a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
index bf73c43..8dd29a4 100644
--- a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
@@ -31,7 +31,7 @@ import static org.apache.camel.test.junit5.TestSupport.deleteDirectory;
public class LevelDBAggregateRecoverWithRedeliveryPolicyTest extends CamelTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private LevelDBAggregationRepository repo;
@Override
diff --git a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
index f5efb6e..e93b11f 100644
--- a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
+++ b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
@@ -31,7 +31,7 @@ import static org.apache.camel.test.junit5.TestSupport.deleteDirectory;
public class LevelDBAggregateRecoverWithSedaTest extends CamelTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private LevelDBAggregationRepository repo;
@Override
diff --git a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
index 1a1f433..fc6b603 100644
--- a/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-leveldb-legacy/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
@@ -32,7 +32,7 @@ import static org.apache.camel.test.junit5.TestSupport.deleteDirectory;
public class LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest extends CamelSpringTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
@Override
protected AbstractXmlApplicationContext createApplicationContext() {
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
index a310abe..23de3e3 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverTest.java
@@ -36,7 +36,7 @@ public class LevelDBAggregateRecoverTest extends LevelDBTestSupport {
private static AtomicInteger getCounter(SerializerType serializerType) {
AtomicInteger counter = counters.get(serializerType);
if (counter == null) {
- counter = new AtomicInteger(0);
+ counter = new AtomicInteger();
counters.put(serializerType, counter);
}
return counter;
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
index 952a170..649f303 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithRedeliveryPolicyTest.java
@@ -36,7 +36,7 @@ public class LevelDBAggregateRecoverWithRedeliveryPolicyTest extends LevelDBTest
private static AtomicInteger getCounter(SerializerType serializerType) {
AtomicInteger counter = counters.get(serializerType);
if (counter == null) {
- counter = new AtomicInteger(0);
+ counter = new AtomicInteger();
counters.put(serializerType, counter);
}
return counter;
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
index 55635d6..51b4e88 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBAggregateRecoverWithSedaTest.java
@@ -36,7 +36,7 @@ public class LevelDBAggregateRecoverWithSedaTest extends LevelDBTestSupport {
private static AtomicInteger getCounter(SerializerType serializerType) {
AtomicInteger counter = counters.get(serializerType);
if (counter == null) {
- counter = new AtomicInteger(0);
+ counter = new AtomicInteger();
counters.put(serializerType, counter);
}
return counter;
diff --git a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
index 1a1f433..fc6b603 100644
--- a/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-leveldb/src/test/java/org/apache/camel/component/leveldb/LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest.java
@@ -32,7 +32,7 @@ import static org.apache.camel.test.junit5.TestSupport.deleteDirectory;
public class LevelDBSpringAggregateRecoverWithRedeliveryPolicyTest extends CamelSpringTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
@Override
protected AbstractXmlApplicationContext createApplicationContext() {
diff --git a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java
index 8ea4534..376eeca 100644
--- a/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java
+++ b/components/camel-nsq/src/test/java/org/apache/camel/component/nsq/NsqProducerTest.java
@@ -40,7 +40,7 @@ public class NsqProducerTest extends NsqTestSupport {
template.sendBody("direct:send", TEST_MESSAGE);
- AtomicInteger counter = new AtomicInteger(0);
+ AtomicInteger counter = new AtomicInteger();
NSQLookup lookup = new DefaultNSQLookup();
lookup.addLookupAddress("localhost", 4161);
@@ -67,7 +67,7 @@ public class NsqProducerTest extends NsqTestSupport {
template.sendBody("direct:send", "test" + i);
}
- AtomicInteger counter = new AtomicInteger(0);
+ AtomicInteger counter = new AtomicInteger();
NSQLookup lookup = new DefaultNSQLookup();
lookup.addLookupAddress("localhost", 4161);
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/support/TestPublisher.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/support/TestPublisher.java
index 9e5184f..4a26b2a 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/support/TestPublisher.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/support/TestPublisher.java
@@ -48,7 +48,7 @@ public class TestPublisher<T> implements Publisher<T> {
private Iterator<T> it = data.iterator();
- private AtomicLong requested = new AtomicLong(0);
+ private AtomicLong requested = new AtomicLong();
private Object monitor = new Object();
diff --git a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java
index 1d14750..fc1e42f 100644
--- a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java
+++ b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java
@@ -108,7 +108,7 @@ public class ReactorStreamsServiceSubscriberTest extends ReactorStreamsServiceTe
.count());
// Ensure order is preserved when using a single consumer
- AtomicLong num = new AtomicLong(0);
+ AtomicLong num = new AtomicLong();
endpoint.getExchanges().stream()
.map(x -> x.getIn().getBody(Long.class))
diff --git a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java
index 9d58620..0b040bf 100644
--- a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java
+++ b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java
@@ -73,7 +73,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
context.start();
ProducerTemplate template = context.createProducerTemplate();
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
Flux.from(crs.fromStream("numbers", Integer.class))
.doOnNext(res -> assertEquals(value.incrementAndGet(), res.intValue()))
@@ -98,7 +98,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
final int num = 30;
final CountDownLatch latch = new CountDownLatch(num);
- final AtomicInteger value = new AtomicInteger(0);
+ final AtomicInteger value = new AtomicInteger();
Flux.from(crs.fromStream("tick", Integer.class))
.doOnNext(res -> assertEquals(value.incrementAndGet(), res.intValue()))
@@ -184,7 +184,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
Publisher<Exchange> timer = crs.from("timer:reactive?period=250&repeatCount=3");
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
CountDownLatch latch = new CountDownLatch(3);
Flux.from(timer)
diff --git a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java
index 87eead0..f9e014f 100644
--- a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java
+++ b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java
@@ -109,7 +109,7 @@ public class RxJavaStreamsServiceSubscriberTest extends RxJavaStreamsServiceTest
.count());
// Ensure order is preserved when using a single consumer
- AtomicLong num = new AtomicLong(0);
+ AtomicLong num = new AtomicLong();
endpoint.getExchanges().stream()
.map(x -> x.getIn().getBody(Long.class))
diff --git a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java
index 5e9ea60..942ba2c 100644
--- a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java
+++ b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java
@@ -65,7 +65,7 @@ public class RxJavaStreamsServiceTest extends RxJavaStreamsServiceTestSupport {
context.start();
ProducerTemplate template = context.createProducerTemplate();
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
Flowable.fromPublisher(crs.fromStream("numbers", Integer.class))
.doOnNext(res -> assertEquals(value.incrementAndGet(), res.intValue())).subscribe();
@@ -86,7 +86,7 @@ public class RxJavaStreamsServiceTest extends RxJavaStreamsServiceTestSupport {
final int num = 30;
final CountDownLatch latch = new CountDownLatch(num);
- final AtomicInteger value = new AtomicInteger(0);
+ final AtomicInteger value = new AtomicInteger();
Flowable.fromPublisher(crs.fromStream("tick", Integer.class))
.doOnNext(res -> assertEquals(value.incrementAndGet(), res.intValue())).doOnNext(n -> latch.countDown())
@@ -164,7 +164,7 @@ public class RxJavaStreamsServiceTest extends RxJavaStreamsServiceTestSupport {
Publisher<Exchange> timer = crs.from("timer:reactive?period=250&repeatCount=3");
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
CountDownLatch latch = new CountDownLatch(3);
Flowable.fromPublisher(timer)
@@ -248,7 +248,7 @@ public class RxJavaStreamsServiceTest extends RxJavaStreamsServiceTestSupport {
public void testTo() throws Exception {
context.start();
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
CountDownLatch latch = new CountDownLatch(1);
Flowable.just(1, 2, 3).flatMap(e -> crs.to("bean:hello", e, String.class))
@@ -262,7 +262,7 @@ public class RxJavaStreamsServiceTest extends RxJavaStreamsServiceTestSupport {
public void testToWithExchange() throws Exception {
context.start();
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
CountDownLatch latch = new CountDownLatch(1);
Flowable.just(1, 2, 3).flatMap(e -> crs.to("bean:hello", e)).map(Exchange::getMessage).map(e -> e.getBody(String.class))
@@ -276,7 +276,7 @@ public class RxJavaStreamsServiceTest extends RxJavaStreamsServiceTestSupport {
public void testToFunction() throws Exception {
context.start();
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
CountDownLatch latch = new CountDownLatch(1);
Function<Object, Publisher<String>> fun = crs.to("bean:hello", String.class);
@@ -290,7 +290,7 @@ public class RxJavaStreamsServiceTest extends RxJavaStreamsServiceTestSupport {
public void testToFunctionWithExchange() throws Exception {
context.start();
- AtomicInteger value = new AtomicInteger(0);
+ AtomicInteger value = new AtomicInteger();
CountDownLatch latch = new CountDownLatch(1);
Function<Object, Publisher<Exchange>> fun = crs.to("bean:hello");
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/CamelJmsTestHelper.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/CamelJmsTestHelper.java
index 5cdf07c..4a478d4 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/CamelJmsTestHelper.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/CamelJmsTestHelper.java
@@ -30,7 +30,7 @@ import org.apache.camel.util.FileUtil;
*/
public final class CamelJmsTestHelper {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private CamelJmsTestHelper() {
}
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 40ad4c4..e17e9ab 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
@@ -112,7 +112,7 @@ public abstract class TransactedConsumerSupport extends CamelTestSupport {
.log("Route " + routeNumber + " 1st attempt Body: ${body} | Redeliverd: ${header.JMSRedelivered}")
.to("mock:test.before." + routeNumber)
.process(new Processor() {
- private final AtomicInteger counter = new AtomicInteger(0);
+ private final AtomicInteger counter = new AtomicInteger();
@Override
public void process(Exchange exchange) throws Exception {
diff --git a/components/camel-soroush/src/test/java/org/apache/camel/component/soroushbot/component/ConsumerNativeConcurrentTest.java b/components/camel-soroush/src/test/java/org/apache/camel/component/soroushbot/component/ConsumerNativeConcurrentTest.java
index 2d72269..dc6aae0 100644
--- a/components/camel-soroush/src/test/java/org/apache/camel/component/soroushbot/component/ConsumerNativeConcurrentTest.java
+++ b/components/camel-soroush/src/test/java/org/apache/camel/component/soroushbot/component/ConsumerNativeConcurrentTest.java
@@ -34,7 +34,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class ConsumerNativeConcurrentTest extends SoroushBotTestSupport {
ConcurrentHashMap<String, Thread> userToThread;
- AtomicInteger badThread = new AtomicInteger(0);
+ AtomicInteger badThread = new AtomicInteger();
@Override
protected RoutesBuilder createRouteBuilder() throws Exception {
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TestStoredProcedure.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TestStoredProcedure.java
index e6a9d64..50e100a 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TestStoredProcedure.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TestStoredProcedure.java
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory;
public final class TestStoredProcedure {
- public static final AtomicLong BATCHFN_CALL_COUNTER = new AtomicLong(0);
+ public static final AtomicLong BATCHFN_CALL_COUNTER = new AtomicLong();
private static final Logger LOG = LoggerFactory.getLogger(TestStoredProcedure.class);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java
index 46d680a..453622e 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java
@@ -26,7 +26,7 @@ import org.junit.jupiter.api.Test;
public class JdbcAggregateRecoverTest extends AbstractJdbcAggregationTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
@Override
void configureJdbcAggregationRepository() {
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java
index c315b59..9f9e921 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java
@@ -26,7 +26,7 @@ import org.junit.jupiter.api.Test;
public class JdbcAggregateRecoverWithRedeliveryPolicyTest extends AbstractJdbcAggregationTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
@Override
void configureJdbcAggregationRepository() {
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java
index 3d6b329..0affac8 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java
@@ -26,7 +26,7 @@ import org.junit.jupiter.api.Test;
public class JdbcAggregateRecoverWithSedaTest extends AbstractJdbcAggregationTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
@Override
void configureJdbcAggregationRepository() {
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java
index 8bbc6ae..0deab84 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java
@@ -28,7 +28,7 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
public class JdbcSpringAggregateRecoverWithRedeliveryPolicyTest extends CamelSpringTestSupport {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
@Override
protected AbstractXmlApplicationContext createApplicationContext() {
diff --git a/components/camel-webhook/src/test/java/org/apache/camel/component/webhook/WebhookRegistrationTest.java b/components/camel-webhook/src/test/java/org/apache/camel/component/webhook/WebhookRegistrationTest.java
index 9bc3f1c..724454a 100644
--- a/components/camel-webhook/src/test/java/org/apache/camel/component/webhook/WebhookRegistrationTest.java
+++ b/components/camel-webhook/src/test/java/org/apache/camel/component/webhook/WebhookRegistrationTest.java
@@ -36,8 +36,8 @@ public class WebhookRegistrationTest extends WebhookTestBase {
@BeforeEach
public void initialize() {
- this.registered = new AtomicInteger(0);
- this.unregistered = new AtomicInteger(0);
+ this.registered = new AtomicInteger();
+ this.unregistered = new AtomicInteger();
}
@Test
diff --git a/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanLifecycleTest.java b/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanLifecycleTest.java
index ee90738..5d03047 100644
--- a/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanLifecycleTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanLifecycleTest.java
@@ -137,7 +137,7 @@ public class BeanLifecycleTest extends ContextTestSupport {
}
public static class MyStatefulBean implements Service {
- private static final AtomicInteger INSTANCES = new AtomicInteger(0);
+ private static final AtomicInteger INSTANCES = new AtomicInteger();
public MyStatefulBean() {
INSTANCES.incrementAndGet();
diff --git a/core/camel-core/src/test/java/org/apache/camel/component/file/strategy/MarkerFileExclusiveReadLockStrategyTest.java b/core/camel-core/src/test/java/org/apache/camel/component/file/strategy/MarkerFileExclusiveReadLockStrategyTest.java
index c0f7e70..b37f552 100644
--- a/core/camel-core/src/test/java/org/apache/camel/component/file/strategy/MarkerFileExclusiveReadLockStrategyTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/component/file/strategy/MarkerFileExclusiveReadLockStrategyTest.java
@@ -40,7 +40,7 @@ public class MarkerFileExclusiveReadLockStrategyTest extends ContextTestSupport
private static final Logger LOG = LoggerFactory.getLogger(MarkerFileExclusiveReadLockStrategyTest.class);
private static final int NUMBER_OF_THREADS = 5;
- private AtomicInteger numberOfFilesProcessed = new AtomicInteger(0);
+ private AtomicInteger numberOfFilesProcessed = new AtomicInteger();
@Override
@BeforeEach
diff --git a/core/camel-core/src/test/java/org/apache/camel/component/scheduler/SchedulerRouteTest.java b/core/camel-core/src/test/java/org/apache/camel/component/scheduler/SchedulerRouteTest.java
index 00d6038..3a6b75f 100644
--- a/core/camel-core/src/test/java/org/apache/camel/component/scheduler/SchedulerRouteTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/component/scheduler/SchedulerRouteTest.java
@@ -59,7 +59,7 @@ public class SchedulerRouteTest extends ContextTestSupport {
}
public static class MyBean {
- public AtomicInteger counter = new AtomicInteger(0);
+ public AtomicInteger counter = new AtomicInteger();
public void someMethod() {
LOG.debug("Invoked someMethod()");
diff --git a/core/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java b/core/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java
index 46dfe4e..de5d2e5 100644
--- a/core/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/component/timer/TimerRouteTest.java
@@ -59,7 +59,7 @@ public class TimerRouteTest extends ContextTestSupport {
}
public static class MyBean {
- public AtomicInteger counter = new AtomicInteger(0);
+ public AtomicInteger counter = new AtomicInteger();
public void someMethod() {
LOG.debug("Invoked someMethod()");
diff --git a/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java b/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java
index 791aaaf..354261a 100644
--- a/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/impl/DefaultProducerTemplateAsyncTest.java
@@ -38,7 +38,7 @@ import static org.junit.jupiter.api.Assertions.*;
public class DefaultProducerTemplateAsyncTest extends ContextTestSupport {
- private static final AtomicInteger ORDER = new AtomicInteger(0);
+ private static final AtomicInteger ORDER = new AtomicInteger();
@Test
public void testRequestAsync() throws Exception {
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListInterfaceAnnotationTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListInterfaceAnnotationTest.java
index 78729b4..230411b 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListInterfaceAnnotationTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListInterfaceAnnotationTest.java
@@ -39,7 +39,7 @@ public class BeanRecipientListInterfaceAnnotationTest extends BeanRecipientListT
}
public static class MyBean implements Route {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private int id;
public MyBean() {
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListTest.java
index 3c7f4ad..f9da8f3 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/BeanRecipientListTest.java
@@ -73,7 +73,7 @@ public class BeanRecipientListTest extends ContextTestSupport {
}
public static class MyBean {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private int id;
public MyBean() {
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/BeanRouteTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/BeanRouteTest.java
index c92b2b5..e27ba19 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/BeanRouteTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/BeanRouteTest.java
@@ -84,7 +84,7 @@ public class BeanRouteTest extends ContextTestSupport {
}
public static class MyBean {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
public String body;
private int id;
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java
index ceceb5e..5e3a24e 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java
@@ -66,7 +66,7 @@ public class RoutePerformanceCountTest extends ContextTestSupport {
}
private static class CountProcessor implements Processor {
- private AtomicInteger counter = new AtomicInteger(0);
+ private AtomicInteger counter = new AtomicInteger();
@Override
public void process(Exchange exchange) throws Exception {
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorConcurrencyTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorConcurrencyTest.java
index 78564dd..315c561 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorConcurrencyTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorConcurrencyTest.java
@@ -38,8 +38,8 @@ public class AggregatorConcurrencyTest extends ContextTestSupport {
private static final Logger LOG = LoggerFactory.getLogger(AggregatorConcurrencyTest.class);
- private static final AtomicInteger COUNTER = new AtomicInteger(0);
- private static final AtomicInteger SUM = new AtomicInteger(0);
+ private static final AtomicInteger COUNTER = new AtomicInteger();
+ private static final AtomicInteger SUM = new AtomicInteger();
private final int size = 100;
private final String uri = "direct:start";
diff --git a/core/camel-core/src/test/java/org/apache/camel/util/ReferenceCountTest.java b/core/camel-core/src/test/java/org/apache/camel/util/ReferenceCountTest.java
index 0203d64..2218291 100644
--- a/core/camel-core/src/test/java/org/apache/camel/util/ReferenceCountTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/util/ReferenceCountTest.java
@@ -26,7 +26,7 @@ public class ReferenceCountTest {
@Test
public void testReferenceCount() {
- AtomicInteger cnt = new AtomicInteger(0);
+ AtomicInteger cnt = new AtomicInteger();
ReferenceCount ref = ReferenceCount.on(cnt::incrementAndGet, cnt::decrementAndGet);
diff --git a/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java b/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java
index aee7d6c..1ff9e2a 100644
--- a/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java
+++ b/core/camel-util/src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java
@@ -34,7 +34,7 @@ public class BackOffTimerTest {
@Test
public void testBackOffTimer() throws Exception {
final CountDownLatch latch = new CountDownLatch(1);
- final AtomicInteger counter = new AtomicInteger(0);
+ final AtomicInteger counter = new AtomicInteger();
final ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);
final BackOff backOff = BackOff.builder().delay(100).build();
final BackOffTimer timer = new BackOffTimer(executor);
@@ -68,7 +68,7 @@ public class BackOffTimerTest {
@Test
public void testBackOffTimerWithMaxAttempts() throws Exception {
final CountDownLatch latch = new CountDownLatch(1);
- final AtomicInteger counter = new AtomicInteger(0);
+ final AtomicInteger counter = new AtomicInteger();
final ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);
final BackOff backOff = BackOff.builder().delay(100).maxAttempts(5L).build();
final BackOffTimer timer = new BackOffTimer(executor);
@@ -97,7 +97,7 @@ public class BackOffTimerTest {
@Test
public void testBackOffTimerWithMaxElapsedTime() throws Exception {
final CountDownLatch latch = new CountDownLatch(1);
- final AtomicInteger counter = new AtomicInteger(0);
+ final AtomicInteger counter = new AtomicInteger();
final ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);
final BackOff backOff = BackOff.builder().delay(100).maxElapsedTime(400).build();
final BackOffTimer timer = new BackOffTimer(executor);
diff --git a/tests/camel-itest/src/test/java/org/apache/camel/itest/CamelJmsTestHelper.java b/tests/camel-itest/src/test/java/org/apache/camel/itest/CamelJmsTestHelper.java
index 79271fe..a4d9412 100644
--- a/tests/camel-itest/src/test/java/org/apache/camel/itest/CamelJmsTestHelper.java
+++ b/tests/camel-itest/src/test/java/org/apache/camel/itest/CamelJmsTestHelper.java
@@ -30,7 +30,7 @@ import org.apache.camel.util.FileUtil;
*/
public final class CamelJmsTestHelper {
- private static AtomicInteger counter = new AtomicInteger(0);
+ private static AtomicInteger counter = new AtomicInteger();
private CamelJmsTestHelper() {
}