diff --git a/.github/workflows/snyk-scan.yml b/.github/workflows/snyk-scan.yml
index c95730f..d8d5b31 100644
--- a/.github/workflows/snyk-scan.yml
+++ b/.github/workflows/snyk-scan.yml
@@ -22,6 +22,10 @@ jobs:
with:
args: --all-projects --sarif-file-output=snyk.sarif
+ - name: Handle undefined security-severity
+ run: |
+ sed -i 's/"security-severity": "undefined"/"security-severity": "0"/g' snyk.sarif
+
- name: Check output file
id: out-file
run: |
@@ -32,6 +36,6 @@ jobs:
- name: Upload result to GitHub Code Scanning
if: steps.out-file.outputs.exists == 'true'
- uses: github/codeql-action/upload-sarif@v2
+ uses: github/codeql-action/upload-sarif@v3
with:
sarif_file: snyk.sarif
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 0b1569d..d688069 100644
--- a/pom.xml
+++ b/pom.xml
@@ -7,7 +7,7 @@
aerospike-client-java-reactive
aerospike-client-java-reactive
https://github.com/aerospike/aerospike-client-java-reactive
- 7.1.0
+ 8.1.2
pom
@@ -29,11 +29,11 @@
3.2.1
1.6
- 7.1.0
- 4.1.97.Final
+ 8.1.2
+ 4.1.111.Final
1.5.0
4.13.2
- 2.0.7
+ 2.0.13
@@ -69,7 +69,7 @@
com.aerospike
- aerospike-client
+ aerospike-client-jdk8
${aerospike-client.version}
diff --git a/reactor-client/pom.xml b/reactor-client/pom.xml
index 526a51f..014b6f6 100644
--- a/reactor-client/pom.xml
+++ b/reactor-client/pom.xml
@@ -6,7 +6,7 @@
com.aerospike
aerospike-client-java-reactive
- 7.1.0
+ 8.1.2
aerospike-reactor-client
jar
@@ -19,7 +19,7 @@
UTF-8
UTF-8
- 3.5.8
+ 3.6.7
3.24.2
0.10
@@ -30,7 +30,7 @@
com.aerospike
- aerospike-client
+ aerospike-client-jdk8
diff --git a/reactor-client/src/test/java/com/aerospike/client/reactor/ReactorInfoTest.java b/reactor-client/src/test/java/com/aerospike/client/reactor/ReactorInfoTest.java
index 2a66539..230f7ac 100644
--- a/reactor-client/src/test/java/com/aerospike/client/reactor/ReactorInfoTest.java
+++ b/reactor-client/src/test/java/com/aerospike/client/reactor/ReactorInfoTest.java
@@ -1,12 +1,11 @@
package com.aerospike.client.reactor;
-import com.aerospike.client.AerospikeException;
import com.aerospike.client.reactor.util.Args;
import org.junit.Test;
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
-public class ReactorInfoTest extends ReactorTest{
+public class ReactorInfoTest extends ReactorTest {
public ReactorInfoTest(Args args) {
super(args);
@@ -28,9 +27,7 @@ public void shouldFailOnUnknownCommand() {
Mono mono = reactorClient.info(null, null, "XXX");
StepVerifier.create(mono)
- .expectErrorMatches(throwable -> throwable instanceof AerospikeException
- && throwable.getMessage().equals("Error -1: Unknown info command: [XXX]"))
- .verify();
+ .expectNext("ERROR:4:unrecognized command")
+ .verifyComplete();
}
-
}
diff --git a/reactor-client/src/test/java/com/aerospike/client/reactor/retry/RetryTest.java b/reactor-client/src/test/java/com/aerospike/client/reactor/retry/RetryTest.java
index 2a04a7b..1befd3f 100644
--- a/reactor-client/src/test/java/com/aerospike/client/reactor/retry/RetryTest.java
+++ b/reactor-client/src/test/java/com/aerospike/client/reactor/retry/RetryTest.java
@@ -9,6 +9,7 @@
import com.aerospike.client.cdt.ListOperation;
import com.aerospike.client.cdt.ListReturnType;
import com.aerospike.client.policy.BatchPolicy;
+import com.aerospike.client.policy.Policy;
import com.aerospike.client.query.IndexCollectionType;
import com.aerospike.client.query.IndexType;
import com.aerospike.client.query.Statement;
@@ -44,11 +45,11 @@ public class RetryTest {
public static final Operation[] OPS = new Operation[]{ListOperation.size(LIST_BIN), ListOperation.getByIndex(LIST_BIN, -1, ListReturnType.VALUE)};
public static final AerospikeException.Connection NO_CONNECTION = new AerospikeException.Connection(ResultCode.NO_MORE_CONNECTIONS, "1");
- public static final AerospikeException.Timeout TIMEOUT = new AerospikeException.Timeout(1, false);
+ public static final AerospikeException.Timeout TIMEOUT = new AerospikeException.Timeout(new Policy(), false);
- private IAerospikeReactorClient reactorClient = mock(IAerospikeReactorClient.class);
+ private final IAerospikeReactorClient reactorClient = mock(IAerospikeReactorClient.class);
- private IAerospikeReactorClient retryClient = new AerospikeReactorRetryClient(reactorClient,
+ private final IAerospikeReactorClient retryClient = new AerospikeReactorRetryClient(reactorClient,
retryOnNoMoreConnections());
@Test