From f17773dfe4f17e54dae353b17e2f9183df185a48 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Tue, 14 Feb 2023 10:35:23 +0100 Subject: [PATCH] Adopt to Mockito 5.1 changes. Closes #2504 --- .../LettuceClusterConnectionUnitTests.java | 3 +-- .../LettuceReactiveSubscriptionUnitTests.java | 24 +++++++++---------- .../DefaultClusterOperationsUnitTests.java | 6 ++--- .../data/redis/core/IndexWriterUnitTests.java | 5 ++-- 4 files changed, 17 insertions(+), 21 deletions(-) diff --git a/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceClusterConnectionUnitTests.java b/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceClusterConnectionUnitTests.java index 89f731db1..e1f1a52ff 100644 --- a/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceClusterConnectionUnitTests.java +++ b/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceClusterConnectionUnitTests.java @@ -46,7 +46,6 @@ import org.mockito.Mock; import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoSettings; import org.mockito.quality.Strictness; - import org.springframework.data.redis.connection.ClusterCommandExecutor; import org.springframework.data.redis.connection.ClusterNodeResourceProvider; import org.springframework.data.redis.connection.ClusterTopologyProvider; @@ -307,7 +306,7 @@ class LettuceClusterConnectionUnitTests { int[] slots = new int[] { 9000, 10000 }; connection.clusterDeleteSlots(CLUSTER_NODE_2, slots); - verify(clusterConnection2Mock, times(1)).clusterDelSlots((int[]) any()); + verify(clusterConnection2Mock, times(1)).clusterDelSlots(any(int[].class)); } @Test // DATAREDIS-315 diff --git a/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscriptionUnitTests.java b/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscriptionUnitTests.java index 74a4ec36d..eb0cdac04 100644 --- a/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscriptionUnitTests.java +++ b/src/test/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveSubscriptionUnitTests.java @@ -68,7 +68,7 @@ class LettuceReactiveSubscriptionUnitTests { @Test // DATAREDIS-612 void shouldSubscribeChannels() { - when(pubSubMock.subscribe(any())).thenReturn(Mono.empty()); + when(pubSubMock.subscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); Mono subscribe = subscription.subscribe(getByteBuffer("foo"), getByteBuffer("bar")); @@ -83,7 +83,7 @@ class LettuceReactiveSubscriptionUnitTests { @Test // DATAREDIS-612 void shouldSubscribeChannelsShouldFail() { - when(pubSubMock.subscribe(any())).thenReturn(Mono.error(new RedisConnectionException("Foo"))); + when(pubSubMock.subscribe(any(ByteBuffer[].class))).thenReturn(Mono.error(new RedisConnectionException("Foo"))); Mono subscribe = subscription.subscribe(getByteBuffer("foo"), getByteBuffer("bar")); @@ -93,7 +93,7 @@ class LettuceReactiveSubscriptionUnitTests { @Test // DATAREDIS-612 void shouldSubscribePatterns() { - when(pubSubMock.pSubscribe(any())).thenReturn(Mono.empty()); + when(pubSubMock.pSubscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); Mono subscribe = subscription.pSubscribe(getByteBuffer("foo"), getByteBuffer("bar")); @@ -108,33 +108,33 @@ class LettuceReactiveSubscriptionUnitTests { @Test // DATAREDIS-612 void shouldUnsubscribeChannels() { - when(pubSubMock.subscribe(any())).thenReturn(Mono.empty()); - when(pubSubMock.unsubscribe(any())).thenReturn(Mono.empty()); + when(pubSubMock.subscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); + when(pubSubMock.unsubscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); subscription.subscribe(getByteBuffer("foo"), getByteBuffer("bar")).as(StepVerifier::create).verifyComplete(); subscription.unsubscribe().as(StepVerifier::create).verifyComplete(); assertThat(subscription.getChannels()).isEmpty(); - verify(pubSubMock).unsubscribe(any()); + verify(pubSubMock).unsubscribe(any(ByteBuffer[].class)); } @Test // DATAREDIS-612 void shouldUnsubscribePatterns() { - when(pubSubMock.pSubscribe(any())).thenReturn(Mono.empty()); - when(pubSubMock.pUnsubscribe(any())).thenReturn(Mono.empty()); + when(pubSubMock.pSubscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); + when(pubSubMock.pUnsubscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); subscription.pSubscribe(getByteBuffer("foo"), getByteBuffer("bar")).as(StepVerifier::create).verifyComplete(); subscription.pUnsubscribe().as(StepVerifier::create).verifyComplete(); assertThat(subscription.getPatterns()).isEmpty(); - verify(pubSubMock).pUnsubscribe(any()); + verify(pubSubMock).pUnsubscribe(any(ByteBuffer[].class)); } @Test // DATAREDIS-612 void shouldEmitChannelMessage() { - when(pubSubMock.subscribe(any())).thenReturn(Mono.empty()); + when(pubSubMock.subscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); subscription.subscribe(getByteBuffer("foo"), getByteBuffer("bar")).as(StepVerifier::create).verifyComplete(); Sinks.Many> sink = Sinks.many().unicast() @@ -154,7 +154,7 @@ class LettuceReactiveSubscriptionUnitTests { @Test // DATAREDIS-612 void shouldEmitPatternMessage() { - when(pubSubMock.pSubscribe(any())).thenReturn(Mono.empty()); + when(pubSubMock.pSubscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); subscription.pSubscribe(getByteBuffer("foo*"), getByteBuffer("bar*")).as(StepVerifier::create).verifyComplete(); Sinks.Many> sink = Sinks.many().unicast() @@ -176,7 +176,7 @@ class LettuceReactiveSubscriptionUnitTests { @Test // DATAREDIS-612 void shouldEmitError() { - when(pubSubMock.subscribe(any())).thenReturn(Mono.empty()); + when(pubSubMock.subscribe(any(ByteBuffer[].class))).thenReturn(Mono.empty()); subscription.subscribe(getByteBuffer("foo"), getByteBuffer("bar")).as(StepVerifier::create).verifyComplete(); Sinks.Many> sink = Sinks.many().unicast() diff --git a/src/test/java/org/springframework/data/redis/core/DefaultClusterOperationsUnitTests.java b/src/test/java/org/springframework/data/redis/core/DefaultClusterOperationsUnitTests.java index ff6193403..2a4abd261 100644 --- a/src/test/java/org/springframework/data/redis/core/DefaultClusterOperationsUnitTests.java +++ b/src/test/java/org/springframework/data/redis/core/DefaultClusterOperationsUnitTests.java @@ -27,11 +27,9 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.Mock; -import org.mockito.Mockito; import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoSettings; import org.mockito.quality.Strictness; - import org.springframework.data.redis.connection.RedisClusterCommands.AddSlots; import org.springframework.data.redis.connection.RedisClusterConnection; import org.springframework.data.redis.connection.RedisClusterNode; @@ -142,7 +140,7 @@ class DefaultClusterOperationsUnitTests { clusterOps.addSlots(NODE_1, 1, 2, 3); - verify(connection, times(1)).clusterAddSlots(eq(NODE_1), Mockito. any()); + verify(connection, times(1)).clusterAddSlots(eq(NODE_1), any(int[].class)); } @Test // DATAREDIS-315 @@ -155,7 +153,7 @@ class DefaultClusterOperationsUnitTests { clusterOps.addSlots(NODE_1, new SlotRange(1, 3)); - verify(connection, times(1)).clusterAddSlots(eq(NODE_1), Mockito. any()); + verify(connection, times(1)).clusterAddSlots(eq(NODE_1), any(int[].class)); } @Test // DATAREDIS-315 diff --git a/src/test/java/org/springframework/data/redis/core/IndexWriterUnitTests.java b/src/test/java/org/springframework/data/redis/core/IndexWriterUnitTests.java index 61cf27060..a53bf1c49 100644 --- a/src/test/java/org/springframework/data/redis/core/IndexWriterUnitTests.java +++ b/src/test/java/org/springframework/data/redis/core/IndexWriterUnitTests.java @@ -31,7 +31,6 @@ import org.mockito.Mock; import org.mockito.junit.jupiter.MockitoExtension; import org.mockito.junit.jupiter.MockitoSettings; import org.mockito.quality.Strictness; - import org.springframework.core.convert.converter.Converter; import org.springframework.core.convert.support.GenericConversionService; import org.springframework.dao.InvalidDataAccessApiUsageException; @@ -127,10 +126,10 @@ class IndexWriterUnitTests { writer.removeAllIndexes(KEYSPACE); - ArgumentCaptor captor = ArgumentCaptor.forClass(byte[].class); + ArgumentCaptor captor = ArgumentCaptor.forClass(byte[][].class); verify(connectionMock, times(1)).del(captor.capture()); - assertThat(captor.getAllValues()).contains(indexKey1, indexKey2); + assertThat(captor.getAllValues()).contains(new byte[][] { indexKey1, indexKey2 }); } @Test // DATAREDIS-425