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 2021/01/01 12:12:58 UTC
[camel] branch master updated: better make use of the AtomicXXX
default constructor
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 8cd6b34 better make use of the AtomicXXX default constructor
8cd6b34 is described below
commit 8cd6b34e8bc753520f3153a354beb9765e3f2741
Author: Babak Vahdat <bv...@apache.org>
AuthorDate: Fri Jan 1 13:12:33 2021 +0100
better make use of the AtomicXXX default constructor
---
.../apache/camel/component/azure/eventhubs/EventHubsProducerIT.java | 2 +-
.../org/apache/camel/component/azure/eventhubs/EventProcessorIT.java | 2 +-
.../apache/camel/component/jira/consumer/NewIssuesConsumerTest.java | 4 ++--
.../camel/component/jira/consumer/WatchUpdatesConsumerTest.java | 4 ++--
.../java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java | 2 +-
.../camel/component/reactive/streams/engine/CamelPublisher.java | 2 +-
.../vertx/kafka/operations/VertxKafkaConsumerOperationsTest.java | 2 +-
.../java/org/apache/camel/component/dataset/DataSetEndpointTest.java | 2 +-
.../test/java/org/apache/camel/component/mock/MockEndpointTest.java | 2 +-
.../src/test/java/org/apache/camel/util/backoff/BackOffTimerTest.java | 2 +-
10 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsProducerIT.java b/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsProducerIT.java
index bfc7eeb..30e6a32 100644
--- a/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsProducerIT.java
+++ b/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventHubsProducerIT.java
@@ -68,7 +68,7 @@ class EventHubsProducerIT extends CamelTestSupport {
final String messageBody = RandomStringUtils.randomAlphabetic(30);
final String firstPartition = "0";
- final AtomicBoolean eventExists = new AtomicBoolean(false);
+ final AtomicBoolean eventExists = new AtomicBoolean();
final CompletableFuture<Exchange> resultAsync = template.asyncSend("direct:sendAsync", exchange -> {
exchange.getIn().setHeader(EventHubsConstants.PARTITION_ID, firstPartition);
diff --git a/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventProcessorIT.java b/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventProcessorIT.java
index 0894471..f0273a0 100644
--- a/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventProcessorIT.java
+++ b/components/camel-azure-eventhubs/src/test/java/org/apache/camel/component/azure/eventhubs/EventProcessorIT.java
@@ -74,7 +74,7 @@ public class EventProcessorIT {
@Test
public void testEventProcessingWithBlobCheckpointStore() {
- final AtomicBoolean doneAsync = new AtomicBoolean(false);
+ final AtomicBoolean doneAsync = new AtomicBoolean();
final EventHubProducerAsyncClient producerAsyncClient
= EventHubsClientFactory.createEventHubProducerAsyncClient(configuration);
final Consumer<EventContext> onEvent = eventContext -> {
diff --git a/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewIssuesConsumerTest.java b/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewIssuesConsumerTest.java
index 1487212..76a4cfc 100644
--- a/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewIssuesConsumerTest.java
+++ b/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/NewIssuesConsumerTest.java
@@ -119,7 +119,7 @@ public class NewIssuesConsumerTest extends CamelTestSupport {
Issue issue = createIssue(11);
reset(searchRestClient);
- AtomicBoolean searched = new AtomicBoolean(false);
+ AtomicBoolean searched = new AtomicBoolean();
when(searchRestClient.searchJql(any(), any(), any(), any())).then(invocation -> {
List<Issue> newIissues = new ArrayList<>();
if (!searched.get()) {
@@ -140,7 +140,7 @@ public class NewIssuesConsumerTest extends CamelTestSupport {
Issue issue3 = createIssue(23);
reset(searchRestClient);
- AtomicBoolean searched = new AtomicBoolean(false);
+ AtomicBoolean searched = new AtomicBoolean();
when(searchRestClient.searchJql(any(), any(), any(), any())).then(invocation -> {
List<Issue> newIssues = new ArrayList<>();
if (!searched.get()) {
diff --git a/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/WatchUpdatesConsumerTest.java b/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/WatchUpdatesConsumerTest.java
index 01c019a..f6c7c0e 100644
--- a/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/WatchUpdatesConsumerTest.java
+++ b/components/camel-jira/src/test/java/org/apache/camel/component/jira/consumer/WatchUpdatesConsumerTest.java
@@ -120,7 +120,7 @@ public class WatchUpdatesConsumerTest extends CamelTestSupport {
Issue issue = setPriority(issues.get(0), new Priority(
null, 4L, "High", null, null, null));
reset(searchRestClient);
- AtomicBoolean searched = new AtomicBoolean(false);
+ AtomicBoolean searched = new AtomicBoolean();
when(searchRestClient.searchJql(any(), any(), any(), any())).then(invocation -> {
if (!searched.get()) {
@@ -145,7 +145,7 @@ public class WatchUpdatesConsumerTest extends CamelTestSupport {
null, 4L, "High", null, null, null));
reset(searchRestClient);
- AtomicBoolean searched = new AtomicBoolean(false);
+ AtomicBoolean searched = new AtomicBoolean();
when(searchRestClient.searchJql(any(), any(), any(), any())).then(invocation -> {
if (!searched.get()) {
issues.add(createIssue(4L));
diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java
index 7df3f42..916e043 100644
--- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java
+++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRouteRequestReplyTest.java
@@ -66,7 +66,7 @@ public class JmsRouteRequestReplyTest extends CamelTestSupport {
protected static int maxTasks = 20;
protected static int maxServerTasks = 1;
protected static int maxCalls = 5;
- protected static AtomicBoolean inited = new AtomicBoolean(false);
+ protected static AtomicBoolean inited = new AtomicBoolean();
protected static Map<String, ContextBuilder> contextBuilders = new HashMap<>();
protected static Map<String, RouteBuilder> routeBuilders = new HashMap<>();
diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelPublisher.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelPublisher.java
index 317c80d..be29e83 100644
--- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelPublisher.java
+++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/engine/CamelPublisher.java
@@ -87,7 +87,7 @@ public class CamelPublisher implements Publisher<Exchange>, AutoCloseable {
// subscriber (or their subscription is cancelled)
AtomicInteger counter = new AtomicInteger(subs.size());
// Use just the first exception in the callback when multiple exceptions are thrown
- AtomicReference<Throwable> thrown = new AtomicReference<>(null);
+ AtomicReference<Throwable> thrown = new AtomicReference<>();
callback = ReactiveStreamsHelper.attachCallback(data, (exchange, error) -> {
thrown.compareAndSet(null, error);
diff --git a/components/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaConsumerOperationsTest.java b/components/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaConsumerOperationsTest.java
index 4b34a88..874e986 100644
--- a/components/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaConsumerOperationsTest.java
+++ b/components/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/operations/VertxKafkaConsumerOperationsTest.java
@@ -216,7 +216,7 @@ class VertxKafkaConsumerOperationsTest {
}
private static class Latch {
- private final AtomicBoolean doneFlag = new AtomicBoolean(false);
+ private final AtomicBoolean doneFlag = new AtomicBoolean();
public void done() {
doneFlag.set(true);
diff --git a/core/camel-core/src/test/java/org/apache/camel/component/dataset/DataSetEndpointTest.java b/core/camel-core/src/test/java/org/apache/camel/component/dataset/DataSetEndpointTest.java
index eaf9758..777193d 100644
--- a/core/camel-core/src/test/java/org/apache/camel/component/dataset/DataSetEndpointTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/component/dataset/DataSetEndpointTest.java
@@ -85,7 +85,7 @@ public class DataSetEndpointTest extends ContextTestSupport {
= new DataSetEndpoint("dataset://foo", context.getComponent("dataset"), new SimpleDataSet(10));
endpoint.setInitialDelay(0);
- final AtomicBoolean reported = new AtomicBoolean(false);
+ final AtomicBoolean reported = new AtomicBoolean();
endpoint.setReporter(new Processor() {
public void process(Exchange exchange) throws Exception {
reported.set(true);
diff --git a/core/camel-core/src/test/java/org/apache/camel/component/mock/MockEndpointTest.java b/core/camel-core/src/test/java/org/apache/camel/component/mock/MockEndpointTest.java
index e4beb76..19dc64d 100644
--- a/core/camel-core/src/test/java/org/apache/camel/component/mock/MockEndpointTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/component/mock/MockEndpointTest.java
@@ -530,7 +530,7 @@ public class MockEndpointTest extends ContextTestSupport {
@Test
public void testReporter() throws Exception {
- final AtomicBoolean reported = new AtomicBoolean(false);
+ final AtomicBoolean reported = new AtomicBoolean();
MockEndpoint mock = getMockEndpoint("mock:result");
mock.setExpectedMessageCount(1);
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 1ff9e2a..15bc536 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
@@ -126,7 +126,7 @@ public class BackOffTimerTest {
@Test
public void testBackOffTimerStop() throws Exception {
final CountDownLatch latch = new CountDownLatch(5);
- final AtomicBoolean done = new AtomicBoolean(false);
+ final AtomicBoolean done = new AtomicBoolean();
final ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);
final BackOff backOff = BackOff.builder().delay(100).build();
final BackOffTimer timer = new BackOffTimer(executor);