This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new d082da3e1857 Fix NPE in tests
d082da3e1857 is described below
commit d082da3e18576a42a45ed87741fca078b90bac10
Author: Claus Ibsen <[email protected]>
AuthorDate: Mon Feb 23 09:06:08 2026 +0100
Fix NPE in tests
---
.../camel/processor/aggregate/cassandra/CassandraAggregationIT.java | 4 +++-
.../aggregate/cassandra/CassandraAggregationRepositoryIT.java | 4 +++-
.../aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java | 4 +++-
.../aggregate/cassandra/NamedCassandraAggregationRepositoryIT.java | 4 +++-
.../camel/processor/idempotent/cassandra/CassandraIdempotentIT.java | 4 +++-
.../idempotent/cassandra/CassandraIdempotentRepositoryIT.java | 4 +++-
.../idempotent/cassandra/NamedCassandraIdempotentRepositoryIT.java | 4 +++-
7 files changed, 21 insertions(+), 7 deletions(-)
diff --git
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java
index 002341ebcafb..a0a69a5fa0cb 100644
---
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java
+++
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java
@@ -41,7 +41,9 @@ public class CassandraAggregationIT extends BaseCassandra {
@AfterEach
public void tearDown() {
- aggregationRepository.stop();
+ if (aggregationRepository != null) {
+ aggregationRepository.stop();
+ }
}
@Override
diff --git
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepositoryIT.java
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepositoryIT.java
index ce9999c07bac..f08e56bffed0 100644
---
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepositoryIT.java
+++
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepositoryIT.java
@@ -49,7 +49,9 @@ public class CassandraAggregationRepositoryIT extends
BaseCassandra {
@AfterEach
public void tearDown() throws Exception {
- aggregationRepository.stop();
+ if (aggregationRepository != null) {
+ aggregationRepository.stop();
+ }
}
private boolean exists(String key) {
diff --git
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java
index fa50d7c35a8f..8185d9ee5fe0 100644
---
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java
+++
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java
@@ -43,7 +43,9 @@ public class CassandraAggregationSerializedHeadersIT extends
BaseCassandra {
@AfterEach
public void tearDown() {
- aggregationRepository.stop();
+ if (aggregationRepository != null) {
+ aggregationRepository.stop();
+ }
}
@Override
diff --git
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/NamedCassandraAggregationRepositoryIT.java
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/NamedCassandraAggregationRepositoryIT.java
index f8088cf2711c..32273139cc7a 100644
---
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/NamedCassandraAggregationRepositoryIT.java
+++
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/NamedCassandraAggregationRepositoryIT.java
@@ -50,7 +50,9 @@ public class NamedCassandraAggregationRepositoryIT extends
BaseCassandra {
@AfterEach
public void tearDown() {
- aggregationRepository.stop();
+ if (aggregationRepository != null) {
+ aggregationRepository.stop();
+ }
}
private boolean exists(String key) {
diff --git
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java
index 7502f382b703..90a173e37a7d 100644
---
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java
+++
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java
@@ -39,7 +39,9 @@ public class CassandraIdempotentIT extends BaseCassandra {
@AfterEach
public void tearDown() {
- idempotentRepository.stop();
+ if (idempotentRepository != null) {
+ idempotentRepository.stop();
+ }
}
@Override
diff --git
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentRepositoryIT.java
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentRepositoryIT.java
index c5b5c033fdaa..56f197ca4bde 100644
---
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentRepositoryIT.java
+++
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentRepositoryIT.java
@@ -44,7 +44,9 @@ public class CassandraIdempotentRepositoryIT extends
BaseCassandra {
@AfterEach
public void tearDown() {
- idempotentRepository.stop();
+ if (idempotentRepository != null) {
+ idempotentRepository.stop();
+ }
}
private boolean exists(String key) {
diff --git
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/NamedCassandraIdempotentRepositoryIT.java
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/NamedCassandraIdempotentRepositoryIT.java
index ab6f221b3036..d7091f158659 100644
---
a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/NamedCassandraIdempotentRepositoryIT.java
+++
b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/NamedCassandraIdempotentRepositoryIT.java
@@ -45,7 +45,9 @@ public class NamedCassandraIdempotentRepositoryIT extends
BaseCassandra {
@AfterEach
public void tearDown() {
- idempotentRepository.stop();
+ if (idempotentRepository != null) {
+ idempotentRepository.stop();
+ }
}
private boolean exists(String key) {
